File tree Expand file tree Collapse file tree 1 file changed +0
-32
lines changed
test/integration/change-streams Expand file tree Collapse file tree 1 file changed +0
-32
lines changed Original file line number Diff line number Diff line change @@ -826,38 +826,6 @@ describe('Change Streams', function () {
826826 }
827827 } ) ;
828828
829- it ( 'when invoked with callbacks' , {
830- metadata : { requires : { topology : 'replicaset' } } ,
831- test : function ( done ) {
832- const ops = [ ] ;
833- changeStream . next ( ( ) => {
834- changeStream . next ( ( ) => {
835- ops . push ( lastWrite ( ) ) ;
836-
837- // explicitly close the change stream after the write has begun
838- ops . push ( changeStream . close ( ) ) ;
839-
840- changeStream . next ( err => {
841- try {
842- expect ( err )
843- . property ( 'message' )
844- . to . match ( / C h a n g e S t r e a m i s c l o s e d / ) ;
845- Promise . all ( ops ) . then ( ( ) => done ( ) , done ) ;
846- } catch ( e ) {
847- done ( e ) ;
848- }
849- } ) ;
850- } ) ;
851- } ) ;
852-
853- ops . push (
854- write ( ) . catch ( ( ) => {
855- // ignore
856- } )
857- ) ;
858- }
859- } ) ;
860-
861829 it . skip ( 'when invoked using eventEmitter API' , {
862830 metadata : {
863831 requires : { topology : 'replicaset' }
You can’t perform that action at this time.
0 commit comments