@@ -50,7 +50,7 @@ defmodule Mongo.ChangeStreamTest do
50
50
assert { :ok , % Mongo.InsertOneResult { } } = Mongo . insert_one ( top , "users" , % { name: "Tom" } )
51
51
end
52
52
53
- @ tag :mongo_3_6
53
+ @ tag :rs_required
54
54
test "change stream resumes after HostUnreachable" , c do
55
55
top = c . pid
56
56
catcher = c . catcher
@@ -74,7 +74,7 @@ defmodule Mongo.ChangeStreamTest do
74
74
assert [ { :getMore , [ "ResumableChangeStreamError" ] } ] == EventCatcher . failed_events ( catcher ) |> Enum . map ( fn event -> { event . command_name , event . failure . error_labels } end )
75
75
end
76
76
77
- @ tag :mongo_3_6
77
+ @ tag :rs_required
78
78
test "change stream resumes after HostNotFound" , c do
79
79
top = c . pid
80
80
catcher = c . catcher
@@ -98,7 +98,7 @@ defmodule Mongo.ChangeStreamTest do
98
98
assert [ { :getMore , [ "ResumableChangeStreamError" ] } ] == EventCatcher . failed_events ( catcher ) |> Enum . map ( fn event -> { event . command_name , event . failure . error_labels } end )
99
99
end
100
100
101
- @ tag :mongo_3_6
101
+ @ tag :rs_required
102
102
test "change stream resumes after NetworkTimeout" , c do
103
103
top = c . pid
104
104
catcher = c . catcher
@@ -123,7 +123,7 @@ defmodule Mongo.ChangeStreamTest do
123
123
assert [ { :getMore , [ "ResumableChangeStreamError" ] } ] == EventCatcher . failed_events ( catcher ) |> Enum . map ( fn event -> { event . command_name , event . failure . error_labels } end )
124
124
end
125
125
126
- @ tag :mongo_3_6
126
+ @ tag :rs_required
127
127
test "change stream resumes after ShutdownInProgress" , c do
128
128
top = c . pid
129
129
catcher = c . catcher
@@ -148,7 +148,7 @@ defmodule Mongo.ChangeStreamTest do
148
148
assert [ { :getMore , [ "ResumableChangeStreamError" ] } ] == EventCatcher . failed_events ( catcher ) |> Enum . map ( fn event -> { event . command_name , event . failure . error_labels } end )
149
149
end
150
150
151
- @ tag :mongo_4_3
151
+ @ tag :rs_required
152
152
test "change stream resumes if error contains ResumableChangeStreamError" , c do
153
153
top = c . pid
154
154
catcher = c . catcher
0 commit comments