Struct DispatchBridgeImpl 

pub struct DispatchBridgeImpl { /* private fields */ }

Concrete DispatchBridge wrapping Arc<dyn themql_core::MessageHandler>.

Implementations

impl DispatchBridgeImpl

pub fn new(handler: Arc<dyn MessageHandler>) -> Self

Construct a new dispatch bridge wrapping the given handler.

Trait Implementations

impl Clone for DispatchBridgeImpl

fn clone(&self) -> DispatchBridgeImpl

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl DispatchBridge for DispatchBridgeImpl

fn dispatch<'a>( &'a self, subject: &'a str, payload: &'a Value, ) -> Pin<Box<dyn Future<Output = Result<Value, Error>> + Send + 'a>>

Dispatch a command to subject with the given JSON payload.