Trait RingBufferProxyInterface

pub trait RingBufferProxyInterface: Send + Sync {
    type SetActiveChannelsResponseFut: Future<Output = Result<RingBufferSetActiveChannelsResult, Error>> + Send;
    type StartResponseFut: Future<Output = Result<RingBufferStartResult, Error>> + Send;
    type StopResponseFut: Future<Output = Result<RingBufferStopResult, Error>> + Send;
    type WatchDelayInfoResponseFut: Future<Output = Result<RingBufferWatchDelayInfoResult, Error>> + Send;

    // Required methods
    fn set_active_channels(
        &self,
        payload: &RingBufferSetActiveChannelsRequest,
    ) -> Self::SetActiveChannelsResponseFut;
    fn start(&self, payload: &RingBufferStartRequest) -> Self::StartResponseFut;
    fn stop(&self, payload: &RingBufferStopRequest) -> Self::StopResponseFut;
    fn watch_delay_info(&self) -> Self::WatchDelayInfoResponseFut;
}

Required Associated Types

type SetActiveChannelsResponseFut: Future<Output = Result<RingBufferSetActiveChannelsResult, Error>> + Send

type StartResponseFut: Future<Output = Result<RingBufferStartResult, Error>> + Send

type StopResponseFut: Future<Output = Result<RingBufferStopResult, Error>> + Send

type WatchDelayInfoResponseFut: Future<Output = Result<RingBufferWatchDelayInfoResult, Error>> + Send

Required Methods

fn set_active_channels( &self, payload: &RingBufferSetActiveChannelsRequest, ) -> Self::SetActiveChannelsResponseFut

fn start(&self, payload: &RingBufferStartRequest) -> Self::StartResponseFut

fn stop(&self, payload: &RingBufferStopRequest) -> Self::StopResponseFut

fn watch_delay_info(&self) -> Self::WatchDelayInfoResponseFut

Implementors

impl RingBufferProxyInterface for RingBufferProxy

type SetActiveChannelsResponseFut = QueryResponseFut<Result<RingBufferSetActiveChannelsResponse, RingBufferSetActiveChannelsError>>

type StartResponseFut = QueryResponseFut<Result<RingBufferStartResponse, RingBufferStartError>>

type StopResponseFut = QueryResponseFut<Result<RingBufferStopResponse, RingBufferStopError>>

type WatchDelayInfoResponseFut = QueryResponseFut<Result<RingBufferWatchDelayInfoResponse, RingBufferWatchDelayInfoError>>