File tree 1 file changed +6
-6
lines changed
1 file changed +6
-6
lines changed Original file line number Diff line number Diff line change @@ -1271,18 +1271,18 @@ describe('Change Streams', function() {
1271
1271
1272
1272
// The actual test we wish to run
1273
1273
test : function ( done ) {
1274
- var configuration = this . configuration ;
1274
+ const configuration = this . configuration ;
1275
1275
const stream = require ( 'stream' ) ;
1276
1276
const client = configuration . newClient ( ) ;
1277
1277
1278
1278
client . connect ( function ( err , client ) {
1279
1279
assert . ifError ( err ) ;
1280
1280
1281
- var theDatabase = client . db ( 'integration_tests' ) ;
1282
- var theCollection = theDatabase . collection ( 'pipeTest' ) ;
1283
- var thisChangeStream = theCollection . watch ( pipeline ) ;
1281
+ const theDatabase = client . db ( 'integration_tests' ) ;
1282
+ const theCollection = theDatabase . collection ( 'pipeTest' ) ;
1283
+ const thisChangeStream = theCollection . watch ( pipeline ) ;
1284
1284
1285
- var outStream = new stream . PassThrough ( { objectMode : true } ) ;
1285
+ const outStream = new stream . PassThrough ( { objectMode : true } ) ;
1286
1286
1287
1287
// Make a stream transforming to JSON and piping to the file
1288
1288
thisChangeStream . stream ( { transform : JSON . stringify } ) . pipe ( outStream ) ;
@@ -1294,7 +1294,7 @@ describe('Change Streams', function() {
1294
1294
outStream
1295
1295
. on ( 'data' , data => {
1296
1296
try {
1297
- var parsedEvent = JSON . parse ( data ) ;
1297
+ const parsedEvent = JSON . parse ( data ) ;
1298
1298
assert . equal ( parsedEvent . fullDocument . a , 1 ) ;
1299
1299
close ( ) ;
1300
1300
} catch ( e ) {
You can’t perform that action at this time.
0 commit comments