Removed unnecessary line

clininger · clininger · commit cbdd31a18353 · 2018-12-09T23:08:41.000+07:00
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`