Struct ChannelBuilder

pub struct ChannelBuilder<SF, CS = (), MH = (), MSG = ()> { /* private fields */ }

Implementations

impl<SF> ChannelBuilder<SF>

where SF: SerdeFormat,

pub fn new(serde_format: SF) -> ChannelBuilder<SF>

impl<SF, MSG> ChannelBuilder<SF, (), (), MSG>

where SF: SerdeFormat,

pub fn call_and_serve<T, S: RpcServiceSchema, CS>( self, service: impl FnOnce(XyRpcChannel<SF, CS>) -> T, ) -> ChannelBuilder<SF, CS, FnServiceFactory<impl FnOnce(XyRpcChannel<SF, CS>) -> RpcMsgHandlerWrapper<T>, (CS, S)>, MSG>

where CS: RpcServiceSchema, RpcMsgHandlerWrapper<T>: RpcMsgHandler<S>,

pub fn only_serve<T, S: RpcServiceSchema>( self, service: impl FnOnce(XyRpcChannel<SF>) -> T, ) -> ChannelBuilder<SF, (), FnServiceFactory<impl FnOnce(XyRpcChannel<SF>) -> RpcMsgHandlerWrapper<T>, ((), S)>, MSG>

where RpcMsgHandlerWrapper<T>: RpcMsgHandler<S>,

impl<F, MH, MSG> ChannelBuilder<F, (), MH, MSG>

pub fn only_call<CS: RpcServiceSchema>(self) -> ChannelBuilder<F, CS, MH, MSG>

impl<SF, CS, MH, MSG> ChannelBuilder<SF, CS, MH, MSG>

where SF: SerdeFormat,

pub fn build_from_read_write( self, (read, write): (impl AsyncRead + Unpin + MaybeSend + 'static, impl AsyncWrite + Unpin + MaybeSend + 'static), ) -> (XyRpcChannel<SF, CS>, impl Future<Output = Result<(), RpcError>> + MaybeSend + 'static)

where XyRpcChannel<SF, CS>: Clone, CS: RpcServiceSchema, MH: ServiceFactory<SF, CS>,

pub fn build_from_transport( self, transport_sink: impl RpcTransportSink + Unpin, transport_stream: impl RpcTransportStream + Unpin, ) -> (XyRpcChannel<SF, CS>, impl Future<Output = Result<(), RpcError>> + MaybeSend + 'static)

where XyRpcChannel<SF, CS>: Clone, CS: RpcServiceSchema, MH: ServiceFactory<SF, CS>,

Trait Implementations

impl<SF: SerdeFormat> Clone for ChannelBuilder<SF, (), ()>

fn clone(&self) -> Self

Returns a duplicate of the value.

const fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.