Lines Matching refs:sink
8998 var sink = new TransformStreamSink(this, startPromise);
8999 this._writable = new WritableStream(sink, writableStrategy);
11334 messageHandler.on('GetReader', function (data, sink) {
11347 sink.onPull = function () {
11353 sink.close();
11358 sink.enqueue(new Uint8Array(value), 1, [value]);
11360 sink.error(reason);
11364 sink.onCancel = function (reason) {
11397 messageHandler.on('GetRangeReader', function (data, sink) {
11403 sink.close();
11407 sink.onPull = function () {
11413 sink.close();
11418 sink.enqueue(new Uint8Array(value), 1, [value]);
11420 sink.error(reason);
11424 sink.onCancel = function (reason) {