Struct ClientProxy 

pub struct ClientProxy { /* private fields */ }

Nest-like client proxy wrapper over a configured Transport.

Implementations

impl ClientProxy

pub fn new(transport: Arc<dyn Transport>) -> Self

pub async fn send<TReq, TRes>( &self, pattern: &str, payload: &TReq, ) -> Result<TRes, TransportError>

where TReq: Serialize + Send + Sync, TRes: for<'de> Deserialize<'de> + Send,

pub async fn emit<TReq>( &self, pattern: &str, payload: &TReq, ) -> Result<(), TransportError>

where TReq: Serialize + Send + Sync,

Trait Implementations

impl Clone for ClientProxy

fn clone(&self) -> ClientProxy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Injectable for ClientProxy

fn construct(_registry: &ProviderRegistry) -> Arc<Self>

fn scope() -> ProviderScope

Provider scope used when the module registers this type.

fn on_module_init<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn on_module_destroy<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn on_application_bootstrap<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,

fn on_application_shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where 'life0: 'async_trait, Self: 'async_trait,