pub trait OutgoingHandler: Client {
    // Provided methods
    fn invoke_handle(
        &self,
        request: Request<impl Stream<Item = Bytes> + Send + 'static, impl Future<Output = Option<Fields>> + Send + 'static>,
        options: Option<RequestOptions>
    ) -> impl Future<Output = Result<(Result<IncomingResponse, ErrorCode>, Self::Transmission)>> + Send { ... }
    fn serve_handle(
        &self
    ) -> impl Future<Output = Result<impl Stream<Item = Result<AcceptedInvocation<Self::Context, (IncomingRequest, Option<RequestOptions>), Self::Subject, <Self::Acceptor as Acceptor>::Transmitter>>>>> + Send { ... }
}

Provided Methods§

source

fn invoke_handle( &self, request: Request<impl Stream<Item = Bytes> + Send + 'static, impl Future<Output = Option<Fields>> + Send + 'static>, options: Option<RequestOptions> ) -> impl Future<Output = Result<(Result<IncomingResponse, ErrorCode>, Self::Transmission)>> + Send

source

fn serve_handle( &self ) -> impl Future<Output = Result<impl Stream<Item = Result<AcceptedInvocation<Self::Context, (IncomingRequest, Option<RequestOptions>), Self::Subject, <Self::Acceptor as Acceptor>::Transmitter>>>>> + Send

Object Safety§

This trait is not object safe.

Implementors§