Striot.Nodes.TCP
connectTCP :: Store alpha => String -> TCPConfig -> Metrics -> InChan (Event alpha) -> IO () Source #
sendStreamTCP :: Store alpha => String -> TCPConfig -> Metrics -> Stream alpha -> IO () Source #
processSocket :: Store alpha => String -> TCPConfig -> Metrics -> IO (Stream alpha) Source #