Lines Matching refs:streamId

16761   this.streamId = 1;
16817       } else if (data.streamId) {
16872     var streamId = this.streamId++;
16878         _this2.streamControllers[streamId] = {
16888           streamId: streamId,
16897         _this2.streamControllers[streamId].pullCall = pullCapability;
16903           streamId: streamId,
16911         _this2.streamControllers[streamId].cancelCall = cancelCapability;
16912         _this2.streamControllers[streamId].isClosed = true;
16919           streamId: streamId
16931     var streamId = data.streamId;
16948         streamId: streamId,
16987         delete self.streamSinks[streamId];
17009     this.streamSinks[streamId] = streamSink;
17028     var streamId = data.streamId;
17040         streamId: streamId,
17046 …treamControllers[data.streamId].startCall, _this4.streamControllers[data.streamId].pullCall, _this…
17049         delete _this4.streamControllers[data.streamId];
17055 …resolveOrReject(this.streamControllers[data.streamId].startCall, data.success, wrapReason(data.rea…
17059 …resolveOrReject(this.streamControllers[data.streamId].pullCall, data.success, wrapReason(data.reas…
17063         if (!this.streamSinks[data.streamId]) {
17071         if (this.streamSinks[data.streamId].desiredSize <= 0 && data.desiredSize > 0) {
17072           this.streamSinks[data.streamId].sinkCapability.resolve();
17075         this.streamSinks[data.streamId].desiredSize = data.desiredSize;
17076         resolveCall(this.streamSinks[data.streamId].onPull).then(function () {
17091 … (0, _util.assert)(this.streamControllers[data.streamId], 'enqueue should have stream controller');
17093         if (!this.streamControllers[data.streamId].isClosed) {
17094           this.streamControllers[data.streamId].controller.enqueue(data.chunk);
17100 …   (0, _util.assert)(this.streamControllers[data.streamId], 'close should have stream controller');
17102         if (this.streamControllers[data.streamId].isClosed) {
17106         this.streamControllers[data.streamId].isClosed = true;
17107         this.streamControllers[data.streamId].controller.close();
17112 …   (0, _util.assert)(this.streamControllers[data.streamId], 'error should have stream controller');
17113         this.streamControllers[data.streamId].controller.error(wrapReason(data.reason));
17118 …resolveOrReject(this.streamControllers[data.streamId].cancelCall, data.success, wrapReason(data.re…
17123         if (!this.streamSinks[data.streamId]) {
17127 …resolveCall(this.streamSinks[data.streamId].onCancel, [wrapReason(data.reason)]).then(function () {
17139         this.streamSinks[data.streamId].sinkCapability.reject(wrapReason(data.reason));
17140         this.streamSinks[data.streamId].isCancelled = true;
17141         delete this.streamSinks[data.streamId];