From cbdd31a183531983526c45c716a866f670fe8ff8 Mon Sep 17 00:00:00 2001
From: clininger <baeldung@clininger.net>
Date: Sun, 9 Dec 2018 23:08:41 +0700
Subject: [PATCH] Removed unnecessary line

---
 .../src/main/java/com/baeldung/rsocket/FireNForgetClient.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/rsocket/src/main/java/com/baeldung/rsocket/FireNForgetClient.java b/rsocket/src/main/java/com/baeldung/rsocket/FireNForgetClient.java
index 6c7362a008..496b3fc5c9 100644
--- 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();
     }