Method write

crates/celld/js/node_stream.js:42–58

(buf)

      }
    }
    write(buf) {
      if (typeof buf === "string") return buf;
      const u8 = buf instanceof Uint8Array
        ? buf : new Uint8Array(buf.buffer ?? buf);
      if (this.__td) return this.__td.decode(u8, { stream: true });
      let bytes = u8;
      if (this.__rem !== undefined) {
        const joined = this.__rem
          ? Buffer.concat([this.__rem, u8]) : Buffer.from(u8);
        const keep = joined.length % 3;
        this.__rem = keep ? joined.slice(joined.length - keep) : null;
        bytes = joined.slice(0, joined.length - keep);
      }
      return Buffer.from(
        bytes.buffer, bytes.byteOffset, bytes.byteLength,
      ).toString(this.encoding);
    }
    end(buf) {
      let out = buf !== undefined && buf.length ? this.write(buf) : "";
      if (this.__td) out += this.__td.decode();