Merge pull request #9 from pandachris/BAEL-2283

Removed unnecessary line
2018-12-09 23:10:39 +07:00 · 2018-12-09 23:10:39 +07:00 · d80ab0b85f
parent bbdc8abc14 cbdd31a183
commit d80ab0b85f
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();
    }