Lines Matching refs:stream
185 function errorOrDestroy(stream, err, sync) {
192 const r = stream._readableState;
193 const w = stream._writableState;
200 stream.destroy(err);
212 process.nextTick(emitErrorNT, stream, err);
214 emitErrorNT(stream, err);
219 function construct(stream, cb) {
220 if (typeof stream._construct !== 'function') {
224 const r = stream._readableState;
225 const w = stream._writableState;
234 stream.once(kConstruct, cb);
236 if (stream.listenerCount(kConstruct) > 1) {
241 process.nextTick(constructNT, stream);
244 function constructNT(stream) {
249 errorOrDestroy(stream, err ?? new ERR_MULTIPLE_CALLBACK());
254 const r = stream._readableState;
255 const w = stream._writableState;
266 stream.emit(kDestroy, err);
268 errorOrDestroy(stream, err, true);
270 stream.emit(kConstruct);
275 stream._construct((err) => {
283 function isRequest(stream) {
284 return stream?.setHeader && typeof stream.abort === 'function';
287 function emitCloseLegacy(stream) {
288 stream.emit('close');
291 function emitErrorCloseLegacy(stream, err) {
292 stream.emit('error', err);
293 process.nextTick(emitCloseLegacy, stream);
297 function destroyer(stream, err) {
298 if (!stream || isDestroyed(stream)) {
302 if (!err && !isFinished(stream)) {
307 if (isServerRequest(stream)) {
308 stream.socket = null;
309 stream.destroy(err);
310 } else if (isRequest(stream)) {
311 stream.abort();
312 } else if (isRequest(stream.req)) {
313 stream.req.abort();
314 } else if (typeof stream.destroy === 'function') {
315 stream.destroy(err);
316 } else if (typeof stream.close === 'function') {
318 stream.close();
320 process.nextTick(emitErrorCloseLegacy, stream, err);
322 process.nextTick(emitCloseLegacy, stream);
325 if (!stream.destroyed) {
326 stream[kIsDestroyed] = true;