| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Data.Conduit.Network.Unix
Synopsis
- sourceSocket :: forall (m :: Type -> Type) i. MonadIO m => Socket -> ConduitT i ByteString m ()
- sinkSocket :: forall (m :: Type -> Type) o. MonadIO m => Socket -> ConduitT ByteString o m ()
- data AppDataUnix
- appSource :: forall ad (m :: Type -> Type) i. (HasReadWrite ad, MonadIO m) => ad -> ConduitT i ByteString m ()
- appSink :: forall ad (m :: Type -> Type) o. (HasReadWrite ad, MonadIO m) => ad -> ConduitT ByteString o m ()
- data ServerSettingsUnix
- serverSettings :: FilePath -> ServerSettingsUnix
- runUnixServer :: ServerSettingsUnix -> (AppDataUnix -> IO ()) -> IO a
- data ClientSettingsUnix
- clientSettings :: FilePath -> ClientSettingsUnix
- runUnixClient :: ClientSettingsUnix -> (AppDataUnix -> IO a) -> IO a
- getPath :: HasPath a => a -> FilePath
- getAfterBind :: HasAfterBind a => a -> Socket -> IO ()
- setPath :: HasPath a => FilePath -> a -> a
- setAfterBind :: HasAfterBind a => (Socket -> IO ()) -> a -> a
Basic utilities
sourceSocket :: forall (m :: Type -> Type) i. MonadIO m => Socket -> ConduitT i ByteString m () Source #
Stream data from the socket.
This function does not automatically close the socket.
Since 0.0.0
sinkSocket :: forall (m :: Type -> Type) o. MonadIO m => Socket -> ConduitT ByteString o m () Source #
Stream data to the socket.
This function does not automatically close the socket.
Since 0.0.0
Simple server/client interface
data AppDataUnix Source #
The data passed to a Unix domain sockets Application.
Instances
| HasReadWrite AppDataUnix Source # | |
Defined in Data.Streaming.Network Methods readLens :: Functor f => (IO ByteString -> f (IO ByteString)) -> AppDataUnix -> f AppDataUnix Source # writeLens :: Functor f => ((ByteString -> IO ()) -> f (ByteString -> IO ())) -> AppDataUnix -> f AppDataUnix Source # | |
appSource :: forall ad (m :: Type -> Type) i. (HasReadWrite ad, MonadIO m) => ad -> ConduitT i ByteString m () Source #
appSink :: forall ad (m :: Type -> Type) o. (HasReadWrite ad, MonadIO m) => ad -> ConduitT ByteString o m () Source #
Server
data ServerSettingsUnix Source #
Settings for a Unix domain sockets server.
Instances
| HasAfterBind ServerSettingsUnix Source # | |
Defined in Data.Streaming.Network Methods afterBindLens :: Functor f => ((Socket -> IO ()) -> f (Socket -> IO ())) -> ServerSettingsUnix -> f ServerSettingsUnix Source # | |
| HasPath ServerSettingsUnix Source # | |
Defined in Data.Streaming.Network Methods pathLens :: Functor f => (FilePath -> f FilePath) -> ServerSettingsUnix -> f ServerSettingsUnix Source # | |
| HasReadBufferSize ServerSettingsUnix Source # | Since 0.1.13 |
Defined in Data.Streaming.Network Methods readBufferSizeLens :: Functor f => (Int -> f Int) -> ServerSettingsUnix -> f ServerSettingsUnix Source # | |
runUnixServer :: ServerSettingsUnix -> (AppDataUnix -> IO ()) -> IO a Source #
Run an Application with the given settings. This function will create a
new listening socket, accept connections on it, and spawn a new thread for
each connection.
Client
data ClientSettingsUnix Source #
Settings for a Unix domain sockets client.
Instances
| HasPath ClientSettingsUnix Source # | |
Defined in Data.Streaming.Network Methods pathLens :: Functor f => (FilePath -> f FilePath) -> ClientSettingsUnix -> f ClientSettingsUnix Source # | |
| HasReadBufferSize ClientSettingsUnix Source # | Since 0.1.14 |
Defined in Data.Streaming.Network Methods readBufferSizeLens :: Functor f => (Int -> f Int) -> ClientSettingsUnix -> f ClientSettingsUnix Source # | |
runUnixClient :: ClientSettingsUnix -> (AppDataUnix -> IO a) -> IO a Source #
Run an Application by connecting to the specified server.
Getters
getAfterBind :: HasAfterBind a => a -> Socket -> IO () Source #
Setters
setAfterBind :: HasAfterBind a => (Socket -> IO ()) -> a -> a Source #