pub trait BusProxyInterface: Send + Sync {
type EnsurePublishResponseFut: Future<Output = Result<(), Error>> + Send;
type GetClientsResponseFut: Future<Output = Result<Vec<String>, Error>> + Send;
type WaitForClientsResponseFut: Future<Output = Result<(bool, Option<Vec<String>>), Error>> + Send;
type WaitForEvent_ResponseFut: Future<Output = Result<bool, Error>> + Send;
// Required methods
fn publish(&self, data: &Event) -> Result<(), Error>;
fn ensure_publish(&self, data: &Event) -> Self::EnsurePublishResponseFut;
fn get_clients(&self) -> Self::GetClientsResponseFut;
fn wait_for_clients(
&self,
clients: &[String],
timeout: i64,
) -> Self::WaitForClientsResponseFut;
fn wait_for_event_(
&self,
data: &Event,
timeout: i64,
) -> Self::WaitForEvent_ResponseFut;
}Required Associated Types§
type EnsurePublishResponseFut: Future<Output = Result<(), Error>> + Send
type GetClientsResponseFut: Future<Output = Result<Vec<String>, Error>> + Send
type WaitForClientsResponseFut: Future<Output = Result<(bool, Option<Vec<String>>), Error>> + Send
type WaitForEvent_ResponseFut: Future<Output = Result<bool, Error>> + Send
Required Methods§
fn publish(&self, data: &Event) -> Result<(), Error>
fn ensure_publish(&self, data: &Event) -> Self::EnsurePublishResponseFut
fn get_clients(&self) -> Self::GetClientsResponseFut
fn wait_for_clients( &self, clients: &[String], timeout: i64, ) -> Self::WaitForClientsResponseFut
fn wait_for_event_( &self, data: &Event, timeout: i64, ) -> Self::WaitForEvent_ResponseFut
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".