File tree Expand file tree Collapse file tree 1 file changed +12
-16
lines changed
test/integration/change-streams Expand file tree Collapse file tree 1 file changed +12
-16
lines changed Original file line number Diff line number Diff line change @@ -2315,14 +2315,12 @@ describe('ChangeStream resumability', function () {
2315
2315
await collection . insertOne ( { name : 'bailey' } ) ;
2316
2316
await changeStream . next ( ) ;
2317
2317
2318
- const mock = sinon
2319
- . stub ( changeStream . cursor , 'getMore' )
2320
- . callsFake ( ( _batchSize , callback ) => {
2321
- mock . restore ( ) ;
2322
- const error = new MongoServerError ( { message : message } ) ;
2323
- error . code = code ;
2324
- callback ( error ) ;
2325
- } ) ;
2318
+ const mock = sinon . stub ( changeStream . cursor , 'getMore' ) . callsFake ( async _batchSize => {
2319
+ mock . restore ( ) ;
2320
+ const error = new MongoServerError ( { message : message } ) ;
2321
+ error . code = code ;
2322
+ throw error ;
2323
+ } ) ;
2326
2324
2327
2325
try {
2328
2326
// tryNext is not blocking and on sharded clusters we don't have control of when
@@ -2459,14 +2457,12 @@ describe('ChangeStream resumability', function () {
2459
2457
await collection . insertOne ( { city : 'New York City' } ) ;
2460
2458
await changeStreamIterator . next ( ) ;
2461
2459
2462
- const mock = sinon
2463
- . stub ( changeStream . cursor , 'getMore' )
2464
- . callsFake ( ( _batchSize , callback ) => {
2465
- mock . restore ( ) ;
2466
- const error = new MongoServerError ( { message } ) ;
2467
- error . code = code ;
2468
- callback ( error ) ;
2469
- } ) ;
2460
+ const mock = sinon . stub ( changeStream . cursor , 'getMore' ) . callsFake ( async _batchSize => {
2461
+ mock . restore ( ) ;
2462
+ const error = new MongoServerError ( { message } ) ;
2463
+ error . code = code ;
2464
+ throw error ;
2465
+ } ) ;
2470
2466
2471
2467
const docs = [ { city : 'Seattle' } , { city : 'Boston' } ] ;
2472
2468
await collection . insertMany ( docs ) ;
You can’t perform that action at this time.
0 commit comments