| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
PMS.Infra.Socket.DS.Core
Synopsis
- app :: AppContext ()
- src :: ConduitT () SocketCommand AppContext ()
- cmd2task :: ConduitT SocketCommand (IOTask ()) AppContext ()
- sink :: ConduitT (IOTask ()) Void AppContext ()
- genEchoTask :: SocketEchoCommandData -> AppContext (IOTask ())
- echoTask :: TQueue McpResponse -> SocketEchoCommandData -> String -> IOTask ()
- genSocketOpenTask :: SocketOpenCommandData -> AppContext (IOTask ())
- socketOpenTask :: SocketOpenCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> String -> String -> IOTask ()
- genSocketCloseTask :: SocketCloseCommandData -> AppContext (IOTask ())
- socketCloseTask :: SocketCloseCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> IOTask ()
- genSocketReadTask :: SocketReadCommandData -> AppContext (IOTask ())
- socketReadTask :: SocketReadCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> Int -> Int -> IOTask ()
- genSocketWriteTask :: SocketWriteCommandData -> AppContext (IOTask ())
- socketWriteTask :: SocketWriteCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> [Word8] -> IOTask ()
- genSocketMessageTask :: SocketMessageCommandData -> AppContext (IOTask ())
- socketMessageTask :: SocketMessageCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> TMVar () -> String -> [String] -> Int -> IOTask ()
- genSocketTelnetTask :: SocketTelnetCommandData -> AppContext (IOTask ())
- socketTelnetTask :: SocketTelnetCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> TMVar () -> String -> String -> [String] -> Int -> IOTask ()
Documentation
app :: AppContext () Source #
src :: ConduitT () SocketCommand AppContext () Source #
cmd2task :: ConduitT SocketCommand (IOTask ()) AppContext () Source #
genEchoTask :: SocketEchoCommandData -> AppContext (IOTask ()) Source #
echoTask :: TQueue McpResponse -> SocketEchoCommandData -> String -> IOTask () Source #
genSocketOpenTask :: SocketOpenCommandData -> AppContext (IOTask ()) Source #
socketOpenTask :: SocketOpenCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> String -> String -> IOTask () Source #
genSocketCloseTask :: SocketCloseCommandData -> AppContext (IOTask ()) Source #
socketCloseTask :: SocketCloseCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> IOTask () Source #
genSocketReadTask :: SocketReadCommandData -> AppContext (IOTask ()) Source #
socketReadTask :: SocketReadCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> Int -> Int -> IOTask () Source #
genSocketWriteTask :: SocketWriteCommandData -> AppContext (IOTask ()) Source #
socketWriteTask :: SocketWriteCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> [Word8] -> IOTask () Source #
socketMessageTask :: SocketMessageCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> TMVar () -> String -> [String] -> Int -> IOTask () Source #
socketTelnetTask :: SocketTelnetCommandData -> TQueue McpResponse -> TMVar (Maybe Socket) -> TMVar () -> String -> String -> [String] -> Int -> IOTask () Source #