From a10826824145df8bd6d0bf4c7ee3ac5eba08bee0 Mon Sep 17 00:00:00 2001 From: Stephane Maldini Date: Thu, 12 May 2016 09:36:28 +0100 Subject: [PATCH] fix emit --- .../http/server/reactive/ChannelSendOperatorTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/ChannelSendOperatorTests.java b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/ChannelSendOperatorTests.java index c65fe4facb..7db972ebd2 100644 --- a/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/ChannelSendOperatorTests.java +++ b/spring-web-reactive/src/test/java/org/springframework/http/server/reactive/ChannelSendOperatorTests.java @@ -110,7 +110,7 @@ public class ChannelSendOperatorTests { IllegalStateException error = new IllegalStateException("boo"); Flux publisher = Flux.generate(() -> 0, (idx , subscriber) -> { int i = ++idx; - subscriber.tryEmit(String.valueOf(i)); + subscriber.next(String.valueOf(i)); if (i == 3) { subscriber.fail(error); }