File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change @@ -135,6 +135,7 @@ def notify(*args)
135
135
subject . add_observer ( obs , observer_func )
136
136
end
137
137
trigger_observable ( subject )
138
+ latch . wait ( 1 )
138
139
latch . count . should eq 0
139
140
end
140
141
@@ -144,6 +145,7 @@ def notify(*args)
144
145
subject . add_observer { latch . count_down }
145
146
end
146
147
trigger_observable ( subject )
148
+ latch . wait ( 1 )
147
149
latch . count . should eq 0
148
150
end
149
151
@@ -155,6 +157,7 @@ def notify(*args)
155
157
subject . delete_observer ( obs )
156
158
157
159
trigger_observable ( subject )
160
+ latch . wait ( 1 )
158
161
latch . count . should eq 5
159
162
end
160
163
@@ -167,6 +170,7 @@ def notify(*args)
167
170
subject . delete_observers
168
171
169
172
trigger_observable ( subject )
173
+ latch . wait ( 1 )
170
174
latch . count . should eq 5
171
175
end
172
176
end
You can’t perform that action at this time.
0 commit comments