Lines Matching refs:stream
23 const Stream = require('stream');
73 const kStream = Symbol('stream');
162 // Cause the request stream to end as well.
202 function resumeStream(stream) {
203 stream.resume();
207 has(stream, prop) {
208 const ref = stream.session !== undefined ? stream.session[kSocket] : stream;
209 return (prop in stream) || (prop in ref);
212 get(stream, prop) {
219 return FunctionPrototypeBind(stream[prop], stream);
222 return stream[prop];
224 if (stream.destroyed)
226 const request = stream[kRequest];
227 return request ? request.readable : stream.readable;
230 const session = stream.session;
233 return FunctionPrototypeBind(stream.setTimeout, stream);
241 const ref = stream.session !== undefined ?
242 stream.session[kSocket] : stream;
250 getPrototypeOf(stream) {
251 if (stream.session !== undefined)
252 return ReflectGetPrototypeOf(stream.session[kSocket]);
253 return ReflectGetPrototypeOf(stream);
255 set(stream, prop, value) {
265 stream[prop] = value;
268 const session = stream.session;
272 stream.setTimeout = value;
281 const ref = stream.session !== undefined ?
282 stream.session[kSocket] : stream;
319 constructor(stream, headers, options, rawHeaders) {
332 this[kStream] = stream;
334 stream[kProxySocket] = null;
335 stream[kRequest] = this;
337 // Pause the stream..
338 stream.on('trailers', onStreamTrailers);
339 stream.on('end', onStreamEnd);
340 stream.on('error', onStreamError);
341 stream.on('aborted', onStreamAbortedRequest);
342 stream.on('close', onStreamCloseRequest);
343 stream.on('timeout', onStreamTimeout(kRequest));
359 get stream() {
392 const stream = this[kStream];
393 const proxySocket = stream[kProxySocket];
395 return stream[kProxySocket] = new Proxy(stream, proxySocketHandler);
476 constructor(stream, options) {
488 this[kStream] = stream;
489 stream[kProxySocket] = null;
490 stream[kResponse] = this;
492 this.req = stream[kRequest];
493 stream.on('drain', onStreamDrain);
494 stream.on('aborted', onStreamAbortedResponse);
495 stream.on('close', onStreamCloseResponse);
496 stream.on('wantTrailers', onStreamTrailersReady);
497 stream.on('timeout', onStreamTimeout(kResponse));
523 const stream = this[kStream];
524 const proxySocket = stream[kProxySocket];
526 return stream[kProxySocket] = new Proxy(stream, proxySocketHandler);
534 get stream() {
675 if (state.closed || this.stream.destroyed)
749 const stream = this[kStream];
750 if (!stream.headersSent)
752 return stream.write(chunk, encoding, cb);
756 const stream = this[kStream];
768 state.headRequest === stream.headRequest) {
778 state.headRequest = stream.headRequest;
782 if (stream.writableEnded)
785 stream.once('finish', cb);
788 if (!stream.headersSent)
791 if (this[kState].closed || stream.destroyed)
792 ReflectApply(onStreamCloseResponse, stream, []);
794 stream.end();
819 this[kStream].pushStream(headers, {}, (err, stream, headers, options) => {
824 callback(null, new Http2ServerResponse(stream));
842 const stream = this[kStream];
843 if (stream.headersSent || this[kState].closed)
845 stream.additionalHeaders({
868 const stream = this[kStream];
870 if (stream.headersSent || this[kState].closed)
873 stream.additionalHeaders({
884 stream, headers, flags, rawHeaders) {
886 const request = new ServerRequest(stream, headers, undefined, rawHeaders);
887 const response = new ServerResponse(stream);