From 6e8c20ed7060900b5ec899d94f915285c57aec41 Mon Sep 17 00:00:00 2001
From: Cory Benfield <lukasa@apple.com>
Date: Wed, 23 Oct 2019 17:49:33 -0700
Subject: [PATCH] Take advantage of flatSubmit. (#62)

Motivation:

We can remove a couple of unnecessary flatMap { $0 } operations by way
of using flatSubmit, added in NIO 2.9.0.

Modifications:

- Replace flatMap { $0 } with flatSubmit().

Result:

Remove some code noise.
---
 Sources/NIOTransportServices/NIOTSConnectionBootstrap.swift | 4 ++--
 Sources/NIOTransportServices/NIOTSListenerBootstrap.swift   | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/Sources/NIOTransportServices/NIOTSConnectionBootstrap.swift b/Sources/NIOTransportServices/NIOTSConnectionBootstrap.swift
index 9a65699..2d28b39 100644
--- a/Sources/NIOTransportServices/NIOTSConnectionBootstrap.swift
+++ b/Sources/NIOTransportServices/NIOTSConnectionBootstrap.swift
@@ -169,7 +169,7 @@ public final class NIOTSConnectionBootstrap {
         let initializer = self.channelInitializer ?? { _ in conn.eventLoop.makeSucceededFuture(()) }
         let channelOptions = self.channelOptions
 
-        return conn.eventLoop.submit {
+        return conn.eventLoop.flatSubmit {
             return channelOptions.applyAllChannelOptions(to: conn).flatMap {
                 initializer(conn)
             }.flatMap {
@@ -191,7 +191,7 @@ public final class NIOTSConnectionBootstrap {
                 conn.close(promise: nil)
                 throw $0
             }
-        }.flatMap { $0 }
+        }
     }
 }
 
diff --git a/Sources/NIOTransportServices/NIOTSListenerBootstrap.swift b/Sources/NIOTransportServices/NIOTSListenerBootstrap.swift
index 7098d58..19a1635 100644
--- a/Sources/NIOTransportServices/NIOTSListenerBootstrap.swift
+++ b/Sources/NIOTransportServices/NIOTSListenerBootstrap.swift
@@ -347,9 +347,9 @@ private class AcceptHandler: ChannelInboundHandler {
         if childLoop === ctxEventLoop {
             fireThroughPipeline(setupChildChannel())
         } else {
-            fireThroughPipeline(childLoop.submit {
+            fireThroughPipeline(childLoop.flatSubmit {
                 return setupChildChannel()
-            }.flatMap { $0 }.hop(to: ctxEventLoop))
+            }.hop(to: ctxEventLoop))
         }
     }
 }