Lines Matching refs:streamId

55535   this.streamId = 1;
55591       } else if (data.streamId) {
55646     var streamId = this.streamId++;
55652         _this2.streamControllers[streamId] = {
55662           streamId: streamId,
55671         _this2.streamControllers[streamId].pullCall = pullCapability;
55677           streamId: streamId,
55685         _this2.streamControllers[streamId].cancelCall = cancelCapability;
55686         _this2.streamControllers[streamId].isClosed = true;
55693           streamId: streamId
55705     var streamId = data.streamId;
55722         streamId: streamId,
55761         delete self.streamSinks[streamId];
55783     this.streamSinks[streamId] = streamSink;
55802     var streamId = data.streamId;
55814         streamId: streamId,
55820 …treamControllers[data.streamId].startCall, _this4.streamControllers[data.streamId].pullCall, _this…
55823         delete _this4.streamControllers[data.streamId];
55829 …resolveOrReject(this.streamControllers[data.streamId].startCall, data.success, wrapReason(data.rea…
55833 …resolveOrReject(this.streamControllers[data.streamId].pullCall, data.success, wrapReason(data.reas…
55837         if (!this.streamSinks[data.streamId]) {
55845         if (this.streamSinks[data.streamId].desiredSize <= 0 && data.desiredSize > 0) {
55846           this.streamSinks[data.streamId].sinkCapability.resolve();
55849         this.streamSinks[data.streamId].desiredSize = data.desiredSize;
55850         resolveCall(this.streamSinks[data.streamId].onPull).then(function () {
55865 … (0, _util.assert)(this.streamControllers[data.streamId], 'enqueue should have stream controller');
55867         if (!this.streamControllers[data.streamId].isClosed) {
55868           this.streamControllers[data.streamId].controller.enqueue(data.chunk);
55874 …   (0, _util.assert)(this.streamControllers[data.streamId], 'close should have stream controller');
55876         if (this.streamControllers[data.streamId].isClosed) {
55880         this.streamControllers[data.streamId].isClosed = true;
55881         this.streamControllers[data.streamId].controller.close();
55886 …   (0, _util.assert)(this.streamControllers[data.streamId], 'error should have stream controller');
55887         this.streamControllers[data.streamId].controller.error(wrapReason(data.reason));
55892 …resolveOrReject(this.streamControllers[data.streamId].cancelCall, data.success, wrapReason(data.re…
55897         if (!this.streamSinks[data.streamId]) {
55901 …resolveCall(this.streamSinks[data.streamId].onCancel, [wrapReason(data.reason)]).then(function () {
55913         this.streamSinks[data.streamId].sinkCapability.reject(wrapReason(data.reason));
55914         this.streamSinks[data.streamId].isCancelled = true;
55915         delete this.streamSinks[data.streamId];