diff --git a/src/Quasar/Network/Multiplexer.hs b/src/Quasar/Network/Multiplexer.hs index abc0998c90a4179d69a52e0b4e887e35a67487e5..445f51264f02a3e7ff0093cc9d42f419c57d0cac 100644 --- a/src/Quasar/Network/Multiplexer.hs +++ b/src/Quasar/Network/Multiplexer.hs @@ -160,7 +160,7 @@ data MultiplexerSide = MultiplexerSideA | MultiplexerSideB newMultiplexer :: (IsConnection a) => MultiplexerSide -> a -> IO Channel newMultiplexer side x = do channelMVar <- newEmptyMVar - -- 'runMultiplexerProtcol' needs to be interruptible (so it can terminate when it is closed), so 'interruptible' is used to ensure that this function also works when used in 'bracket' + -- 'runMultiplexer' needs to be interruptible (so it can terminate when it is closed), so 'interruptible' is used to ensure that this function also works when used in 'bracket' mask_ $ link =<< async (interruptible (runMultiplexer side (putMVar channelMVar) (toSocketConnection x))) takeMVar channelMVar diff --git a/test/Quasar/Network/MultiplexerSpec.hs b/test/Quasar/Network/MultiplexerSpec.hs index 129128824f0c532192080f41bf27298453fe8339..399db6bf821ca8387f4daffef35280befd38cf91 100644 --- a/test/Quasar/Network/MultiplexerSpec.hs +++ b/test/Quasar/Network/MultiplexerSpec.hs @@ -13,7 +13,7 @@ import Network.Socket import Test.Hspec spec :: Spec -spec = describe "runMultiplexerProtocol" $ parallel $ do +spec = describe "runMultiplexer" $ parallel $ do it "can be closed from the channelSetupHook" $ do (x, _) <- newDummySocketPair runMultiplexer MultiplexerSideA channelClose x