Documentation

request :: forall a o r. Members [Process RpcMessage o, Responses RequestId Response !! RpcError, Log, Stop RpcError] r => Text -> Request -> (Object -> Either DecodeError a) -> Sem r a Source #

handleCall :: RpcCall a -> (Request -> (Object -> Either DecodeError a) -> Sem r a) -> Sem r a Source #

fetchChannelId :: Member (AtomicState (Maybe ChannelId)) r => Members [Process RpcMessage o, Responses RequestId Response !! RpcError, Log, Stop RpcError] r => Sem r ChannelId Source #

cachedChannelId :: Member (AtomicState (Maybe ChannelId)) r => Members [Process RpcMessage o, Responses RequestId Response !! RpcError, Log, Stop RpcError] r => Sem r ChannelId Source #

interpretRpc :: forall o r. Member (AtomicState (Maybe ChannelId)) r => Members [Responses RequestId Response !! RpcError, Process RpcMessage o, Log, Async] r => InterpreterFor (Rpc !! RpcError) r Source #