Trait wrpc_transport::serve::Serve

pub trait Serve: Sync {
    type Context: Send + Sync + 'static;
    type Outgoing: AsyncWrite + Index<Self::Outgoing> + Send + Sync + Unpin + 'static;
    type Incoming: AsyncRead + Index<Self::Incoming> + Send + Sync + Unpin + 'static;

    // Required method
    fn serve(
        &self,
        instance: &str,
        func: &str,
        paths: impl Into<Arc<[Box<[Option<usize>]>]>> + Send,
    ) -> impl Future<Output = Result<impl Stream<Item = Result<(Self::Context, Self::Outgoing, Self::Incoming)>> + Send + 'static>> + Send;
}

Server-side handle to a wRPC transport

Required Associated Types

type Context: Send + Sync + 'static

Transport-specific invocation context

type Outgoing: AsyncWrite + Index<Self::Outgoing> + Send + Sync + Unpin + 'static

Outgoing multiplexed byte stream

type Incoming: AsyncRead + Index<Self::Incoming> + Send + Sync + Unpin + 'static

Incoming multiplexed byte stream

Required Methods

fn serve( &self, instance: &str, func: &str, paths: impl Into<Arc<[Box<[Option<usize>]>]>> + Send, ) -> impl Future<Output = Result<impl Stream<Item = Result<(Self::Context, Self::Outgoing, Self::Incoming)>> + Send + 'static>> + Send

Serve function func from instance instance

Object Safety

This trait is not object safe.

Implementors

impl<C, I, O> Serve for &Server<C, I, O>

where C: Send + Sync + 'static, I: AsyncRead + Send + Sync + Unpin + 'static, O: AsyncWrite + Send + Sync + Unpin + 'static,

type Context = C

type Outgoing = Outgoing

type Incoming = Incoming

impl<C, I, O> Serve for Server<C, I, O>

where C: Send + Sync + 'static, I: AsyncRead + Send + Sync + Unpin + 'static, O: AsyncWrite + Send + Sync + Unpin + 'static,

type Context = C

type Outgoing = Outgoing

type Incoming = Incoming