Lines Matching refs:error
139 const cleanup = finished(streamWritable, (error) => {
140 if (error?.code === 'ERR_STREAM_PREMATURE_CLOSE') {
141 const err = new AbortError(undefined, { cause: error });
142 error = err;
147 // that happen to emit an error event again after finished is called.
148 streamWritable.on('error', () => {});
149 if (error != null) {
151 backpressurePromise.reject(error);
152 // If closed is not undefined, the error is happening
156 closed.reject(error);
159 controller.error(error);
169 controller.error(new AbortError());
244 function done(error) {
245 error = error.filter((e) => e);
247 callback(error.length === 0 ? undefined : error);
248 } catch (error) {
254 process.nextTick(() => destroy(writable, error));
287 function done(error) {
289 callback(error);
290 } catch (error) {
291 destroy(writable, error);
306 destroy(error, callback) {
309 callback(error);
310 } catch (error) {
316 process.nextTick(() => { throw error; });
321 if (error != null) {
323 writer.abort(error),
339 function done(error) {
341 callback(error);
342 } catch (error) {
348 process.nextTick(() => destroy(writable, error));
365 // ended, we signal an error on the stream.Writable.
370 (error) => {
372 // destroyed, signal an error on the stream.Writable.
374 destroy(writable, error);
442 const cleanup = finished(streamReadable, (error) => {
443 if (error?.code === 'ERR_STREAM_PREMATURE_CLOSE') {
444 const err = new AbortError(undefined, { cause: error });
445 error = err;
450 // that happen to emit an error event again after finished is called.
451 streamReadable.on('error', () => {});
452 if (error)
453 return controller.error(error);
520 (error) => destroy(readable, error));
523 destroy(error, callback) {
526 callback(error);
527 } catch (error) {
533 process.nextTick(() => { throw error; });
539 reader.cancel(error),
553 (error) => {
555 destroy(readable, error);
670 function done(error) {
671 error = error.filter((e) => e);
673 callback(error.length === 0 ? undefined : error);
674 } catch (error) {
680 process.nextTick(() => destroy(duplex, error));
713 function done(error) {
715 callback(error);
716 } catch (error) {
717 destroy(duplex, error);
733 function done(error) {
735 callback(error);
736 } catch (error) {
742 process.nextTick(() => destroy(duplex, error));
764 (error) => destroy(duplex, error));
767 destroy(error, callback) {
770 callback(error);
771 } catch (error) {
777 process.nextTick(() => { throw error; });
783 await writer.abort(error);
788 await reader.cancel(error);
813 (error) => {
816 destroy(duplex, error);
824 (error) => {
827 destroy(duplex, error);
859 const error = errnoException(status, 'write', this.error);
860 this.promise.reject(error);
861 this.controller.error(error);
877 } catch (error) {
878 promise.reject(error);
895 (error) => controller.error(error)) :
944 } catch (error) {
945 controller.error(error);
954 } catch (error) {
955 controller.error(error);
971 } catch (error) {
972 promise.reject(error);