Trait Invoke 

pub trait Invoke: Send + Sync {
    type Context: Send + Sync;

    // Required method
    fn invoke<P>(
        &self,
        cx: Self::Context,
        instance: &str,
        func: &str,
        params: Bytes,
        paths: impl AsRef<[P]> + Send,
    ) -> impl Future<Output = Result<(Outgoing, Incoming)>> + Send
       where P: AsRef<[Option<usize>]> + Send + Sync;
}

Client-side handle to a wRPC transport

Invocations are always multiplexed over the wRPC framing layer, so the outgoing and incoming byte streams are the framed Outgoing and Incoming streams regardless of the underlying transport.

Required Associated Types

type Context: Send + Sync

Transport-specific invocation context

Required Methods

fn invoke<P>( &self, cx: Self::Context, instance: &str, func: &str, params: Bytes, paths: impl AsRef<[P]> + Send, ) -> impl Future<Output = Result<(Outgoing, Incoming)>> + Send

where P: AsRef<[Option<usize>]> + Send + Sync,

Invoke function func on instance instance

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl Invoke for wrpc_transport::frame::unix::Client<&Path>

type Context = ()

impl Invoke for wrpc_transport::frame::unix::Client<&SocketAddr>

type Context = ()

impl Invoke for wrpc_transport::frame::unix::Client<PathBuf>

type Context = ()

impl Invoke for wrpc_transport::frame::unix::Client<SocketAddr>

type Context = ()

impl<I, O> Invoke for &Oneshot<I, O>

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

type Context = ()

impl<I, O> Invoke for Oneshot<I, O>

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

type Context = ()

impl<T: Invoke> Invoke for Timeout<'_, T>

type Context = <T as Invoke>::Context

impl<T: Invoke> Invoke for TimeoutOwned<T>

type Context = <T as Invoke>::Context

impl<T> Invoke for wrpc_transport::frame::tcp::tokio::Client<T>

where T: ToSocketAddrs + Clone + Send + Sync,

type Context = ()