Method push

libraries/stream-extra/src/distribution.ts:28–68

* Pushes data to the combiner. * @param data The input data to be split or combined. * @returns * A generator that yields buffers of specified size. * It may yield the same buffer multiple times, consume the data before calling `next`.

(data: Uint8Array)

     * It may yield the same buffer multiple times, consume the data before calling `next`.
     */
    *push(data: Uint8Array): Generator<Uint8Array, void, void> {
        let offset = 0;
        let available = data.length;

        if (this.#offset !== 0) {
            if (available >= this.#available) {
                this.#buffer.set(
                    data.subarray(0, this.#available),
                    this.#offset,
                );
                offset += this.#available;
                available -= this.#available;

                yield this.#buffer;
                this.#offset = 0;
                this.#available = this.#capacity;

                if (available === 0) {
                    return;
                }
            } else {
                this.#buffer.set(data, this.#offset);
                this.#offset += available;
                this.#available -= available;
                return;
            }
        }

        while (available >= this.#capacity) {
            const end = offset + this.#capacity;
            yield data.subarray(offset, end);
            offset = end;
            available -= this.#capacity;
        }

        if (available > 0) {
            this.#buffer.set(data.subarray(offset), this.#offset);
            this.#offset += available;
            this.#available -= available;
        }
    }

    flush(): Uint8Array | undefined {
        if (this.#offset === 0) {