Trait ChannelProxyInterface

pub trait ChannelProxyInterface: Send + Sync {
    type CreateChannelResponseFut: Future<Output = Result<ChannelCreateChannelResult, Error>> + Send;
    type ReadChannelResponseFut: Future<Output = Result<ChannelReadChannelResult, Error>> + Send;
    type WriteChannelResponseFut: Future<Output = Result<ChannelWriteChannelResult, Error>> + Send;
    type ReadChannelStreamingStartResponseFut: Future<Output = Result<ChannelReadChannelStreamingStartResult, Error>> + Send;
    type ReadChannelStreamingStopResponseFut: Future<Output = Result<ChannelReadChannelStreamingStopResult, Error>> + Send;

    // Required methods
    fn create_channel(
        &self,
        handles: &[NewHandleId; 2],
    ) -> Self::CreateChannelResponseFut;
    fn read_channel(&self, handle: &HandleId) -> Self::ReadChannelResponseFut;
    fn write_channel(
        &self,
        handle: &HandleId,
        data: &[u8],
        handles: &Handles,
    ) -> Self::WriteChannelResponseFut;
    fn read_channel_streaming_start(
        &self,
        handle: &HandleId,
    ) -> Self::ReadChannelStreamingStartResponseFut;
    fn read_channel_streaming_stop(
        &self,
        handle: &HandleId,
    ) -> Self::ReadChannelStreamingStopResponseFut;
}

Required Associated Types

type CreateChannelResponseFut: Future<Output = Result<ChannelCreateChannelResult, Error>> + Send

type ReadChannelResponseFut: Future<Output = Result<ChannelReadChannelResult, Error>> + Send

type WriteChannelResponseFut: Future<Output = Result<ChannelWriteChannelResult, Error>> + Send

type ReadChannelStreamingStartResponseFut: Future<Output = Result<ChannelReadChannelStreamingStartResult, Error>> + Send

type ReadChannelStreamingStopResponseFut: Future<Output = Result<ChannelReadChannelStreamingStopResult, Error>> + Send

Required Methods

fn create_channel( &self, handles: &[NewHandleId; 2], ) -> Self::CreateChannelResponseFut

fn read_channel(&self, handle: &HandleId) -> Self::ReadChannelResponseFut

fn write_channel( &self, handle: &HandleId, data: &[u8], handles: &Handles, ) -> Self::WriteChannelResponseFut

fn read_channel_streaming_start( &self, handle: &HandleId, ) -> Self::ReadChannelStreamingStartResponseFut

fn read_channel_streaming_stop( &self, handle: &HandleId, ) -> Self::ReadChannelStreamingStopResponseFut

Implementors

impl ChannelProxyInterface for ChannelProxy

type CreateChannelResponseFut = QueryResponseFut<Result<(), Error>>

type ReadChannelResponseFut = QueryResponseFut<Result<(Vec<u8>, Vec<HandleInfo>), Error>>

type WriteChannelResponseFut = QueryResponseFut<Result<(), WriteChannelError>>

type ReadChannelStreamingStartResponseFut = QueryResponseFut<Result<(), Error>>

type ReadChannelStreamingStopResponseFut = QueryResponseFut<Result<(), Error>>