Removed unnecessary line

2018-12-09 23:08:41 +07:00 · 2018-12-09 23:08:41 +07:00 · cbdd31a183
parent 24bc616dd2
commit cbdd31a183
1 changed files with 1 additions and 2 deletions
--- 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 class FireNForgetClient {
        Flux.interval(Duration.ofMillis(50))
          .take(data.size())
          .map(this::createFloatPayload)
-          .map(socket::fireAndForget)
-          .flatMap(Function.identity())
+          .flatMap(socket::fireAndForget)
          .blockLast();
    }