Struct ClientBroker

pub struct ClientBroker<T> { /* private fields */ }

Implementations

impl<T> ClientBroker<T>

where T: Debug + Send + 'static + DeserializeOwned + Sync + Clone + Serialize,

pub fn init( network_topology: StdArc<NetworkTopology>, container_state: StdArc<AtomicUsize>, container_state_notify: StdArc<Notify>, ) -> Self

pub async fn handle_message(&self, message: ClientBrokerMessage<T>)

pub async fn forward_shutdown(&mut self, message: T)

pub async fn shutdown(&mut self)

Trait Implementations

impl<T> Drop for ClientBroker<T>

fn drop(&mut self)

Executes the destructor for this type.