File tree Expand file tree Collapse file tree 1 file changed +3
-6
lines changed
test/integration/change-streams Expand file tree Collapse file tree 1 file changed +3
-6
lines changed Original file line number Diff line number Diff line change @@ -41,6 +41,9 @@ const initIteratorMode = async (cs: ChangeStream) => {
41
41
return ;
42
42
} ;
43
43
44
+ const is4_2Server = ( serverVersion : string ) =>
45
+ gte ( serverVersion , '4.2.0' ) && lt ( serverVersion , '4.3.0' ) ;
46
+
44
47
// Define the pipeline processing changes
45
48
const pipeline = [
46
49
{ $addFields : { addedField : 'This is a field added using $addFields' } } ,
@@ -54,9 +57,6 @@ describe('Change Streams', function () {
54
57
let changeStream : ChangeStream ;
55
58
let db : Db ;
56
59
57
- const is4_2Server = ( serverVersion : string ) =>
58
- gte ( serverVersion , '4.2.0' ) && lt ( serverVersion , '4.3.0' ) ;
59
-
60
60
beforeEach ( async function ( ) {
61
61
const configuration = this . configuration ;
62
62
client = configuration . newClient ( ) ;
@@ -1791,9 +1791,6 @@ describe('ChangeStream resumability', function () {
1791
1791
{ error : 'CursorNotFound' , code : 43 , message : 'cursor not found' }
1792
1792
] ;
1793
1793
1794
- const is4_2Server = ( serverVersion : string ) =>
1795
- gte ( serverVersion , '4.2.0' ) && lt ( serverVersion , '4.3.0' ) ;
1796
-
1797
1794
beforeEach ( function ( ) {
1798
1795
assert ( this . currentTest != null ) ;
1799
1796
if (
You can’t perform that action at this time.
0 commit comments