@@ -18,7 +18,7 @@ import qualified Network.WebSockets as WS
1818intercept :: WS.Protocol p
1919 => (WS.Request -> WS.WebSockets p ())
2020 -> Wai.Request
21− -> Maybe (C.BufferedSource (C.ResourceT IO) ByteString -> Warp.Connection -> C.ResourceT IO ())
21+ -> Maybe (C.Source (C.ResourceT IO) ByteString -> Warp.Connection -> C.ResourceT IO ())
2222intercept = interceptWith WS.defaultWebSocketsOptions
2323
2424-- | Variation of 'intercept' which allows custom options.
@@ -26,7 +26,7 @@ interceptWith :: WS.Protocol p
2626 => WS.WebSocketsOptions
2727 -> (WS.Request -> WS.WebSockets p ())
2828 -> Wai.Request
29− -> Maybe (C.BufferedSource (C.ResourceT IO) ByteString -> Warp.Connection -> C.ResourceT IO ())
29+ -> Maybe (C.Source (C.ResourceT IO) ByteString -> Warp.Connection -> C.ResourceT IO ())
3030interceptWith opts app req = case lookup "upgrade" $ Wai.requestHeaders req of
3131 Just s
3232 | S.map toLower s == "websocket" -> Just $ runWebSockets opts req' app
@@ -41,7 +41,7 @@ runWebSockets :: WS.Protocol p
4141 => WS.WebSocketsOptions
4242 -> WS.RequestHttpPart
4343 -> (WS.Request -> WS.WebSockets p ())
44− -> C.BufferedSource (C.ResourceT IO) ByteString
44+ -> C.Source (C.ResourceT IO) ByteString
4545 -> Warp.Connection
4646 -> C.ResourceT IO ()
4747runWebSockets opts req app source conn = do