Trait golem_rpc_api::rpc::wamp::RpcEndpoint

pub trait RpcEndpoint where
    <Self::Response as Future>::Output == Result<RpcCallResponse, Error>, {
    type Response: 'static + Future;
    fn rpc_call(&self, request: RpcCallRequest) -> Self::Response;
}

Associated Types

type Response: 'static + Future

Loading content...

Required methods

fn rpc_call(&self, request: RpcCallRequest) -> Self::Response

Loading content...

Implementations on Foreign Types

impl<Transport> RpcEndpoint for Addr<Connection<SplitSink<Transport, Message>>> where
    Transport: Stream<Item = Result<Frame, ProtocolError>> + Sink<Message, Error = ProtocolError> + Unpin + 'static, 

type Response = Pin<Box<dyn Future<Output = Result<RpcCallResponse, Error>> + 'static>>

fn rpc_call(
    &self,
    request: RpcCallRequest
) -> <Addr<Connection<SplitSink<Transport, Message>>> as RpcEndpoint>::Response

Loading content...

Implementors

Loading content...