Trait golem_rpc_api::rpc::wamp::RpcEndpoint

pub trait RpcEndpoint where
    <Self::Response as Future>::Item == RpcCallResponse,
    <Self::Response as Future>::Error == 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>>> where
    Transport: Stream<Item = Frame, Error = ProtocolError> + Sink<SinkItem = Message, SinkError = ProtocolError> + 'static, 

type Response = Box<dyn Future<Item = RpcCallResponse, Error = Error> + 'static>

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

Loading content...

Implementors

Loading content...