File tree Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Expand file tree Collapse file tree 1 file changed +3
-8
lines changed Original file line number Diff line number Diff line change @@ -1708,7 +1708,6 @@ describe('Cursor', function () {
1708
1708
expect ( cursor ) . property ( 'closed' , false ) ;
1709
1709
1710
1710
const willClose = once ( cursor , 'close' ) ;
1711
- const willEnd = once ( stream , 'close' ) ;
1712
1711
1713
1712
const dataEvents = on ( stream , 'data' ) ;
1714
1713
@@ -1722,16 +1721,12 @@ describe('Cursor', function () {
1722
1721
// After 5 successful data events, destroy stream
1723
1722
stream . destroy ( ) ;
1724
1723
1725
- // We should get a a close event on the stream and a close event on the cursor
1726
- // We should **not** get an 'error' event,
1724
+ // We should get a close event on the stream and a close event on the cursor
1725
+ // We should **not** get an 'error' or an 'end' event,
1727
1726
// the following will throw if either stream or cursor emitted an 'error' event
1728
- await Promise . race ( [
1729
- willEnd ,
1730
- sleep ( 100 , { ref : false } ) . then ( ( ) => Promise . reject ( new Error ( 'end event never emitted' ) ) )
1731
- ] ) ;
1732
1727
await Promise . race ( [
1733
1728
willClose ,
1734
- sleep ( 100 , { ref : false } ) . then ( ( ) => Promise . reject ( new Error ( 'close event never emitted' ) ) )
1729
+ sleep ( 100 ) . then ( ( ) => Promise . reject ( new Error ( 'close event never emitted' ) ) )
1735
1730
] ) ;
1736
1731
} ) ;
1737
1732
You can’t perform that action at this time.
0 commit comments