Spring/spring-framework
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Remove EmitterProcessor#connect (dropped upstream)

Browse Source
This commit is contained in:
Rossen Stoyanchev
2017-04-13 09:58:48 -04:00
parent dce72e0ad0
commit 46a790f9be
1 changed files with 0 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-webmvc/src/test/java/org/springframework/web/servlet/mvc/method/annotation/ReactiveTypeHandlerTests.java
View File

@@ -146,7 +146,6 @@ public class ReactiveTypeHandlerTests {
EmitterProcessor<String> emitter = EmitterProcessor.create(); EmitterProcessor<String> emitter = EmitterProcessor.create();
testDeferredResultSubscriber(emitter, Flux.class, () -> { testDeferredResultSubscriber(emitter, Flux.class, () -> {
emitter.connect();
emitter.onNext("foo"); emitter.onNext("foo");
emitter.onNext("bar"); emitter.onNext("bar");
emitter.onNext("baz"); emitter.onNext("baz");
@@ -233,7 +232,6 @@ public class ReactiveTypeHandlerTests {
EmitterHandler emitterHandler = new EmitterHandler(); EmitterHandler emitterHandler = new EmitterHandler();
sseEmitter.initialize(emitterHandler); sseEmitter.initialize(emitterHandler);
processor.connect();
processor.onNext("foo"); processor.onNext("foo");
processor.onNext("bar"); processor.onNext("bar");
processor.onNext("baz"); processor.onNext("baz");
@@ -253,7 +251,6 @@ public class ReactiveTypeHandlerTests {
EmitterHandler emitterHandler = new EmitterHandler(); EmitterHandler emitterHandler = new EmitterHandler();
sseEmitter.initialize(emitterHandler); sseEmitter.initialize(emitterHandler);
processor.connect();
processor.onNext(ServerSentEvent.builder("foo").id("1").build()); processor.onNext(ServerSentEvent.builder("foo").id("1").build());
processor.onNext(ServerSentEvent.builder("bar").id("2").build()); processor.onNext(ServerSentEvent.builder("bar").id("2").build());
processor.onNext(ServerSentEvent.builder("baz").id("3").build()); processor.onNext(ServerSentEvent.builder("baz").id("3").build());
@@ -277,7 +274,6 @@ public class ReactiveTypeHandlerTests {
ServletServerHttpResponse message = new ServletServerHttpResponse(this.servletResponse); ServletServerHttpResponse message = new ServletServerHttpResponse(this.servletResponse);
emitter.extendResponse(message); emitter.extendResponse(message);
processor.connect();
processor.onNext("[\"foo\",\"bar\"]"); processor.onNext("[\"foo\",\"bar\"]");
processor.onNext("[\"bar\",\"baz\"]"); processor.onNext("[\"bar\",\"baz\"]");
processor.onComplete(); processor.onComplete();
@@ -295,7 +291,6 @@ public class ReactiveTypeHandlerTests {
EmitterHandler emitterHandler = new EmitterHandler(); EmitterHandler emitterHandler = new EmitterHandler();
emitter.initialize(emitterHandler); emitter.initialize(emitterHandler);
processor.connect();
processor.onNext("The quick"); processor.onNext("The quick");
processor.onNext(" brown fox jumps over "); processor.onNext(" brown fox jumps over ");
processor.onNext("the lazy dog"); processor.onNext("the lazy dog");