@@ -135,7 +135,7 @@ public Promise<String> run(final Context context) throws Exception
135
135
136
136
getEngine ().run (task );
137
137
138
- assertTrue (task .await (100 , TimeUnit .MILLISECONDS ));
138
+ assertTrue (task .await (5 , TimeUnit .SECONDS ));
139
139
assertEquals (value , task .get ());
140
140
}
141
141
@@ -165,7 +165,7 @@ public Promise<String> run(final Context context) throws Exception
165
165
166
166
getEngine ().run (task );
167
167
168
- assertTrue (task .await (100 , TimeUnit .MILLISECONDS ));
168
+ assertTrue (task .await (5 , TimeUnit .SECONDS ));
169
169
assertEquals (value , task .get ());
170
170
}
171
171
@@ -209,7 +209,7 @@ public Promise<String> run(final Context context) throws Exception
209
209
210
210
getEngine ().run (task );
211
211
212
- assertTrue (task .await (100 , TimeUnit .MILLISECONDS ));
212
+ assertTrue (task .await (5 , TimeUnit .SECONDS ));
213
213
assertEquals (successorValue , successorTask .get ());
214
214
assertEquals (predecessorValue , predecessorValueRef .get ());
215
215
}
@@ -250,7 +250,7 @@ public void run()
250
250
251
251
getEngine ().run (task );
252
252
253
- task .await ();
253
+ assertTrue ( task .await (5 , TimeUnit . SECONDS ) );
254
254
255
255
final Queue <Integer > ints = task .get ();
256
256
assertEquals ((Integer )2 , ints .poll ());
0 commit comments