From d4cfa4c0e08e94f0068256d10ea283c440af0a00 Mon Sep 17 00:00:00 2001
From: Jens Nolte <git@queezle.net>
Date: Sun, 11 Jul 2021 23:44:45 +0200
Subject: [PATCH] Move code

---
 src/Quasar/Network.hs | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/Quasar/Network.hs b/src/Quasar/Network.hs
index 3f938a7..8af66cb 100644
--- a/src/Quasar/Network.hs
+++ b/src/Quasar/Network.hs
@@ -456,9 +456,6 @@ serverHandleChannelMessage protocolImpl channel resources msg = case decodeOrFai
         wrappedResponse :: ProtocolResponseWrapper p
         wrappedResponse = (resources.messageId, response)
 
-registerChannelServerHandler :: forall p. (RpcProtocol p, HasProtocolImpl p) => ProtocolImpl p -> Channel -> IO ()
-registerChannelServerHandler protocolImpl channel = channelSetHandler channel (serverHandleChannelMessage @p protocolImpl channel)
-
 
 newtype Stream up down = Stream Channel
 
@@ -613,7 +610,10 @@ connectToServer server conn = void $ forkFinally (interruptible (runServerHandle
 
 -- | Internal
 runServerHandler :: forall p a. (RpcProtocol p, HasProtocolImpl p, IsConnection a) => ProtocolImpl p -> a -> IO ()
-runServerHandler protocolImpl = runMultiplexer MultiplexerSideB (registerChannelServerHandler @p protocolImpl) . toSocketConnection
+runServerHandler protocolImpl = runMultiplexer MultiplexerSideB registerChannelServerHandler . toSocketConnection
+  where
+    registerChannelServerHandler :: Channel -> IO ()
+    registerChannelServerHandler channel = channelSetHandler channel (serverHandleChannelMessage @p protocolImpl channel)
 
 
 withLocalClient :: forall p a. (RpcProtocol p, HasProtocolImpl p) => Server p -> ((Client p) -> IO a) -> IO a
-- 
GitLab