Adapt to Reactor Core change for deferring the NonBlocking rejection …

…in toIterable reactor/reactor-core#1318
reactor · Aug 22, 2018 · e079cab · e079cab
1 parent 3373c66
commit e079cab
Show file tree

Hide file tree

Showing 3 changed files with 159 additions and 96 deletions.
diff --git a/src/test/java/reactor/ipc/netty/http/client/HttpClientTest.java b/src/test/java/reactor/ipc/netty/http/client/HttpClientTest.java
@@ -894,9 +894,11 @@ public void closePool() {
 				Flux.range(1, 10)
 				    .concatMap(i -> ws.take(2)
 				                      .log()))
-		            .expectNextSequence(Flux.range(1, 20)
-		                                    .map(v -> "test")
-		                                    .toIterable())
+		            .expectNextSequence(
+		                    Objects.requireNonNull(Flux.range(1, 20)
+		                                               .map(v -> "test")
+		                                               .collectList()
+		                                               .block()))
 		            .expectComplete()
 		            .verify();