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)
135135 subject . add_observer ( obs , observer_func )
136136 end
137137 trigger_observable ( subject )
138+ latch . wait ( 1 )
138139 latch . count . should eq 0
139140 end
140141
@@ -144,6 +145,7 @@ def notify(*args)
144145 subject . add_observer { latch . count_down }
145146 end
146147 trigger_observable ( subject )
148+ latch . wait ( 1 )
147149 latch . count . should eq 0
148150 end
149151
@@ -155,6 +157,7 @@ def notify(*args)
155157 subject . delete_observer ( obs )
156158
157159 trigger_observable ( subject )
160+ latch . wait ( 1 )
158161 latch . count . should eq 5
159162 end
160163
@@ -167,6 +170,7 @@ def notify(*args)
167170 subject . delete_observers
168171
169172 trigger_observable ( subject )
173+ latch . wait ( 1 )
170174 latch . count . should eq 5
171175 end
172176 end
You can’t perform that action at this time.
0 commit comments