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§

Required Methods§

source

fn publish(&self, data: &Event) -> Result<(), Error>

source

fn ensure_publish(&self, data: &Event) -> Self::EnsurePublishResponseFut

source

fn get_clients(&self) -> Self::GetClientsResponseFut

source

fn wait_for_clients( &self, clients: &[String], timeout: i64 ) -> Self::WaitForClientsResponseFut

source

fn wait_for_event_( &self, data: &Event, timeout: i64 ) -> Self::WaitForEvent_ResponseFut

Implementors§

source§

impl BusProxyInterface for BusProxy

§

type EnsurePublishResponseFut = QueryResponseFut<()>

§

type GetClientsResponseFut = QueryResponseFut<Vec<String>>

§

type WaitForClientsResponseFut = QueryResponseFut<(bool, Option<Vec<String>>)>

§

type WaitForEvent_ResponseFut = QueryResponseFut<bool>