Trait BusProxyInterface

Source

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;
}