Construct handlers

mkNonStreaming :: forall {k} (rpc :: k) inp out m. (SupportsStreamingType rpc 'NonStreaming, Binary inp, Input rpc ~ ByteString, Binary out, Output rpc ~ ByteString, MonadIO m) => (inp -> m out) -> ServerHandler' 'NonStreaming m rpc Source #

mkClientStreaming :: forall {k} (rpc :: k) out m. (SupportsStreamingType rpc 'ClientStreaming, Binary out, Output rpc ~ ByteString, MonadIO m) => ((forall inp. (Binary inp, Input rpc ~ ByteString) => m (NextElem inp)) -> m out) -> ServerHandler' 'ClientStreaming m rpc Source #

mkServerStreaming :: forall {k} (rpc :: k) inp m. (SupportsStreamingType rpc 'ServerStreaming, Binary inp, Input rpc ~ ByteString, MonadIO m) => (inp -> (forall out. (Binary out, Output rpc ~ ByteString) => NextElem out -> m ()) -> m ()) -> ServerHandler' 'ServerStreaming m rpc Source #

mkBiDiStreaming :: forall {k} (rpc :: k) m. (SupportsStreamingType rpc 'BiDiStreaming, MonadIO m) => ((forall inp. (Binary inp, Input rpc ~ ByteString) => m (NextElem inp)) -> (forall out. (Binary out, Output rpc ~ ByteString) => NextElem out -> m ()) -> m ()) -> ServerHandler' 'BiDiStreaming m rpc Source #