@@ -593,18 +593,21 @@ class Minipass extends Stream {
593593 const onerr = er => {
594594 this . removeListener ( 'data' , ondata )
595595 this . removeListener ( 'end' , onend )
596+ this . removeListener ( DESTROYED , ondestroy )
596597 stop ( )
597598 reject ( er )
598599 }
599600 const ondata = value => {
600601 this . removeListener ( 'error' , onerr )
601602 this . removeListener ( 'end' , onend )
603+ this . removeListener ( DESTROYED , ondestroy )
602604 this . pause ( )
603605 resolve ( { value : value , done : ! ! this [ EOF ] } )
604606 }
605607 const onend = ( ) => {
606608 this . removeListener ( 'error' , onerr )
607609 this . removeListener ( 'data' , ondata )
610+ this . removeListener ( DESTROYED , ondestroy )
608611 stop ( )
609612 resolve ( { done : true } )
610613 }
@@ -635,6 +638,7 @@ class Minipass extends Stream {
635638 const stop = ( ) => {
636639 this . pause ( )
637640 this . removeListener ( ERROR , stop )
641+ this . removeListener ( DESTROYED , stop )
638642 this . removeListener ( 'end' , stop )
639643 stopped = true
640644 return { done : true }
@@ -647,6 +651,7 @@ class Minipass extends Stream {
647651 }
648652 this . once ( 'end' , stop )
649653 this . once ( ERROR , stop )
654+ this . once ( DESTROYED , stop )
650655
651656 return {
652657 next,
0 commit comments