* Use Flux.subscribe(Consumer) instead of doOnNext(Consumer).subscribe()

artembilan · artembilan · commit f75e027eba5d · 2019-12-02T14:06:08.000-05:00
diff --git a/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java b/spring-integration-core/src/main/java/org/springframework/integration/channel/FluxMessageChannel.java
@@ -54,7 +54,7 @@ public class FluxMessageChannel extends AbstractMessageChannel
 	public FluxMessageChannel() {
 		this.processor = EmitterProcessor.create(1, false);
 		this.sink = this.processor.sink(FluxSink.OverflowStrategy.BUFFER);
-		this.subscribedSignal.doOnNext(this.subscribed::set).subscribe();
+		this.subscribedSignal.subscribe(this.subscribed::set);
 	}
 
 	@Override

Original file line number	Diff line number	Diff line change
`@@ -54,7 +54,7 @@ public class FluxMessageChannel extends AbstractMessageChannel`
`54`	`54`	`public FluxMessageChannel() {`
`55`	`55`	`this.processor = EmitterProcessor.create(1, false);`
`56`	`56`	`this.sink = this.processor.sink(FluxSink.OverflowStrategy.BUFFER);`
`57`		`- this.subscribedSignal.doOnNext(this.subscribed::set).subscribe();`
	`57`	`+ this.subscribedSignal.subscribe(this.subscribed::set);`
`58`	`58`	`}`
`59`	`59`
`60`	`60`	`@Override`