Spaces:
Sleeping
Sleeping
File size: 1,389 Bytes
be5030f |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 |
import { DataType } from '../../type';
import { VectorType as V } from '../../interfaces';
import { Builder, BuilderOptions } from '../../builder/index';
/** @ignore */
export interface BuilderTransformOptions<T extends DataType = any, TNull = any> extends BuilderOptions<T, TNull> {
queueingStrategy?: 'bytes' | 'count';
dictionaryHashFunction?: (value: any) => string | number;
readableStrategy?: {
highWaterMark?: number;
size?: any;
type?: 'bytes';
};
writableStrategy?: {
highWaterMark?: number;
size?: any;
type?: 'bytes';
};
valueToChildTypeId?: (builder: Builder<T, TNull>, value: any, offset: number) => number;
}
/** @ignore */
export declare function builderThroughDOMStream<T extends DataType = any, TNull = any>(options: BuilderTransformOptions<T, TNull>): BuilderTransform<T, TNull>;
/** @ignore */
export declare class BuilderTransform<T extends DataType = any, TNull = any> {
readable: ReadableStream<V<T>>;
writable: WritableStream<T['TValue'] | TNull>;
_controller: ReadableStreamDefaultController<V<T>> | null;
private _numChunks;
private _finished;
private _bufferedSize;
private _builder;
private _getSize;
constructor(options: BuilderTransformOptions<T, TNull>);
private _writeValueAndReturnChunkSize;
private _maybeFlush;
private _enqueue;
}
|