File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
test-common/src/main/java/de/bwaldvogel/mongo/backend Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -467,10 +467,10 @@ public void testMultipleChangeStreams() throws InterruptedException {
467467 Flowable .fromPublisher (asyncCollection .insertOne (json ("_id: 2, bu: 'abc'" ))),
468468 Flowable .fromPublisher (asyncCollection .insertOne (json ("_id: 3, bu: 'xyz'" ))),
469469 Flowable .fromPublisher (asyncCollection .insertOne (json ("_id: 4, bu: 'abc'" )))
470- ).test ().awaitDone (5 , TimeUnit .SECONDS ).assertComplete ();
470+ ).test ().awaitDone (15 , TimeUnit .SECONDS ).assertComplete ();
471471
472472 final Map <Integer , List <ChangeStreamDocument <Document >>> results = streamSubscriber
473- .awaitDone (15 , TimeUnit .SECONDS )
473+ .awaitDone (30 , TimeUnit .SECONDS )
474474 .assertComplete ()
475475 .assertValueCount (1 )
476476 .values ().get (0 );
You can’t perform that action at this time.
0 commit comments