Control.Aff.Sockets

data Connection :: Type

type Port = Int

type Host = String

type TCPOptions opts = { allowHalfOpen :: Boolean, host :: Host, port :: Port | opts }

defaultTCPOptions :: TCPOptions ()

type EmitFunction a r = Emitter Effect a r

type Emitter a r = EmitFunction a r -> Effect Unit

type Left a = a -> Either a Unit

type Right a = Unit -> Either a Unit

createConnectionEmitterImpl :: forall opts. EffectFn4 (Connection -> Step Connection Unit) (Unit -> Step Connection Unit) (TCPOptions opts) (EmitFunction Connection Unit) Unit

createConnectionEmitter :: forall opts. TCPOptions opts -> Emitter Connection Unit

connectionProducer :: forall opts m. MonadAff m => TCPOptions opts -> Producer Connection m Unit

connectToServerImpl :: forall opts. EffectFn1 (TCPOptions opts) Connection

connectToServer :: forall opts m. MonadAff m => TCPOptions opts -> m Connection

createMessageEmitterImpl :: EffectFn2 Connection (String -> Effect Unit) Unit

createMessageEmitter :: Connection -> Emitter String Unit

messageProducer :: forall m. MonadAff m => Connection -> Producer String m Unit

writeMessageImpl :: Fn2 Connection String (Effect Boolean)

writeMessage :: forall m. MonadAff m => Connection -> String -> m Boolean

messageConsumer :: forall m. MonadAff m => Connection -> Consumer String m Unit

type ConnectionProcess m = Connection -> Process m Unit

connectionConsumer :: forall m. MonadAff m => MonadRec m => ConnectionProcess m -> Consumer Connection m Unit

dataProducer :: forall a m f. Decode a => MonadAff m => MonadRec m => Parallel f m => Connection -> Producer (Either MultipleErrors a) m Unit

From a connection, produce instances of a, or possibly a list of de-serialisation errors.

writeData :: forall m a. Encode a => MonadAff m => Connection -> a -> m Boolean

dataConsumer :: forall a m. Encode a => MonadAff m => Connection -> Consumer a m Unit

dataProducer_ :: forall a m f. Decode a => MonadAff m => MonadRec m => Parallel f m => Connection -> Producer a m Unit