| Safe Haskell | None |
|---|---|
| Language | Haskell2010 |
Network.GRPC.Client.StreamType.Conduit
Contents
Description
Conduit interface
Synopsis
- clientStreaming :: forall {k} m (rpc :: k) r. MonadIO m => Connection -> ClientHandler' 'ClientStreaming (ReaderT Connection m) rpc -> (ConduitT (Input rpc) Void m () -> m r) -> m (Output rpc, r)
- clientStreaming_ :: forall {k} m (rpc :: k). MonadIO m => Connection -> ClientHandler' 'ClientStreaming (ReaderT Connection m) rpc -> (ConduitT (Input rpc) Void m () -> m ()) -> m (Output rpc)
- serverStreaming :: forall {k} m (rpc :: k) r. MonadIO m => Connection -> ClientHandler' 'ServerStreaming (ReaderT Connection m) rpc -> Input rpc -> (ConduitT () (Output rpc) m () -> m r) -> m r
- biDiStreaming :: forall {k} (rpc :: k) m r. MonadIO m => Connection -> ClientHandler' 'BiDiStreaming (ReaderT Connection m) rpc -> (ConduitT (Input rpc) Void m () -> ConduitT () (Output rpc) m () -> m r) -> m r
Run client handlers
clientStreaming :: forall {k} m (rpc :: k) r. MonadIO m => Connection -> ClientHandler' 'ClientStreaming (ReaderT Connection m) rpc -> (ConduitT (Input rpc) Void m () -> m r) -> m (Output rpc, r) Source #
clientStreaming_ :: forall {k} m (rpc :: k). MonadIO m => Connection -> ClientHandler' 'ClientStreaming (ReaderT Connection m) rpc -> (ConduitT (Input rpc) Void m () -> m ()) -> m (Output rpc) Source #
serverStreaming :: forall {k} m (rpc :: k) r. MonadIO m => Connection -> ClientHandler' 'ServerStreaming (ReaderT Connection m) rpc -> Input rpc -> (ConduitT () (Output rpc) m () -> m r) -> m r Source #
biDiStreaming :: forall {k} (rpc :: k) m r. MonadIO m => Connection -> ClientHandler' 'BiDiStreaming (ReaderT Connection m) rpc -> (ConduitT (Input rpc) Void m () -> ConduitT () (Output rpc) m () -> m r) -> m r Source #