Merge pull request eugenp#9 from pandachris/BAEL-2283

pandachris · web-flow · commit d80ab0b85ff2 · 2018-12-09T23:10:39.000+07:00
Removed unnecessary line
diff --git a/rsocket/src/main/java/com/baeldung/rsocket/FireNForgetClient.java b/rsocket/src/main/java/com/baeldung/rsocket/FireNForgetClient.java
@@ -38,8 +38,7 @@ public void sendData() {
         Flux.interval(Duration.ofMillis(50))
           .take(data.size())
           .map(this::createFloatPayload)
-          .map(socket::fireAndForget)
-          .flatMap(Function.identity())
+          .flatMap(socket::fireAndForget)
           .blockLast();
     }
 

Original file line number	Diff line number	Diff line change
`@@ -38,8 +38,7 @@ public void sendData() {`
`38`	`38`	`Flux.interval(Duration.ofMillis(50))`
`39`	`39`	`.take(data.size())`
`40`	`40`	`.map(this::createFloatPayload)`
`41`		`- .map(socket::fireAndForget)`
`42`		`- .flatMap(Function.identity())`
	`41`	`+ .flatMap(socket::fireAndForget)`
`43`	`42`	`.blockLast();`
`44`	`43`	`}`
`45`	`44`