Memory leak? about irc-conduit HOT 4 CLOSED

--- a/Network/IRC/Client/Internal.hs
+++ b/Network/IRC/Client/Internal.hs
@@ -118,16 +118,17 @@ forgetful = awaitForever go where
 -- | Block on receiving a message and invoke all matching handlers
 -- concurrently.
 eventSink :: MonadIO m => IRCState s -> Consumer IrcEvent m ()
-eventSink ircstate = await >>= maybe (return ()) (\event -> do
-  let event'  = decodeUtf8 <$> event
-  ignored <- isIgnored ircstate event'
-  unless ignored $ do
-    handlers <- getHandlersFor event' . _eventHandlers <$> getInstanceConfig' ircstate
-    liftIO $ mapM_ (\h -> forkIO $ runReaderT (h event') ircstate) handlers                                                                                                                                           
-
-  -- If disconnected, do not loop.
-  disconnected <- (==Disconnected) <$> getConnState ircstate
-  unless disconnected (eventSink ircstate))
+eventSink ircstate = go where
+  go = await >>= maybe (return ()) (\event -> do
+    let event'  = decodeUtf8 <$> event
+    ignored <- isIgnored ircstate event'
+    unless ignored $ do
+      handlers <- getHandlersFor event' . _eventHandlers <$> getInstanceConfig' ircstate
+      liftIO $ mapM_ (\h -> forkIO $ runReaderT (h event') ircstate) handlers
+
+    -- If disconnected, do not loop.
+    disconnected <- (==Disconnected) <$> getConnState ircstate
+    unless disconnected go)

--- a/Network/IRC/Conduit/Internal/Conduits.hs
+++ b/Network/IRC/Conduit/Internal/Conduits.hs
@@ -1,3 +1,4 @@
+{-# LANGUAGE BangPatterns      #-}
 {-# LANGUAGE OverloadedStrings #-}
 {-# LANGUAGE RankNTypes        #-}

@@ -7,7 +8,7 @@
 -- License     : MIT
 -- Maintainer  : Michael Walker <[email protected]>
 -- Stability   : experimental
--- Portability : OverloadedStrings, RankNTypes
+-- Portability : BangPatterns, OverloadedStrings, RankNTypes
 --
 -- Internal helper conduits. This module is NOT considered to form
 -- part of the public interface of this library.
@@ -25,7 +26,7 @@ import qualified Data.ByteString as B
 chunked :: Monad m => Conduit ByteString m ByteString
 chunked = chunked' ""
   where
-    chunked' leftover = do
+    chunked' !leftover = do
       -- Wait for a value from upstream
       val <- await