Trait SocketProxyInterface

pub trait SocketProxyInterface: Send + Sync {
    type CreateSocketResponseFut: Future<Output = Result<SocketCreateSocketResult, Error>> + Send;
    type SetSocketDispositionResponseFut: Future<Output = Result<SocketSetSocketDispositionResult, Error>> + Send;
    type ReadSocketResponseFut: Future<Output = Result<SocketReadSocketResult, Error>> + Send;
    type WriteSocketResponseFut: Future<Output = Result<SocketWriteSocketResult, Error>> + Send;
    type ReadSocketStreamingStartResponseFut: Future<Output = Result<SocketReadSocketStreamingStartResult, Error>> + Send;
    type ReadSocketStreamingStopResponseFut: Future<Output = Result<SocketReadSocketStreamingStopResult, Error>> + Send;

    // Required methods
    fn create_socket(
        &self,
        options: SocketType,
        handles: &[NewHid; 2],
    ) -> Self::CreateSocketResponseFut;
    fn set_socket_disposition(
        &self,
        handle: &Hid,
        disposition: SocketDisposition,
        disposition_peer: SocketDisposition,
    ) -> Self::SetSocketDispositionResponseFut;
    fn read_socket(
        &self,
        handle: &Hid,
        max_bytes: u64,
    ) -> Self::ReadSocketResponseFut;
    fn write_socket(
        &self,
        handle: &Hid,
        data: &[u8],
    ) -> Self::WriteSocketResponseFut;
    fn read_socket_streaming_start(
        &self,
        handle: &Hid,
    ) -> Self::ReadSocketStreamingStartResponseFut;
    fn read_socket_streaming_stop(
        &self,
        handle: &Hid,
    ) -> Self::ReadSocketStreamingStopResponseFut;
}

Required Associated Types

type CreateSocketResponseFut: Future<Output = Result<SocketCreateSocketResult, Error>> + Send

type SetSocketDispositionResponseFut: Future<Output = Result<SocketSetSocketDispositionResult, Error>> + Send

type ReadSocketResponseFut: Future<Output = Result<SocketReadSocketResult, Error>> + Send

type WriteSocketResponseFut: Future<Output = Result<SocketWriteSocketResult, Error>> + Send

type ReadSocketStreamingStartResponseFut: Future<Output = Result<SocketReadSocketStreamingStartResult, Error>> + Send

type ReadSocketStreamingStopResponseFut: Future<Output = Result<SocketReadSocketStreamingStopResult, Error>> + Send

Required Methods

fn create_socket( &self, options: SocketType, handles: &[NewHid; 2], ) -> Self::CreateSocketResponseFut

fn set_socket_disposition( &self, handle: &Hid, disposition: SocketDisposition, disposition_peer: SocketDisposition, ) -> Self::SetSocketDispositionResponseFut

fn read_socket( &self, handle: &Hid, max_bytes: u64, ) -> Self::ReadSocketResponseFut

fn write_socket( &self, handle: &Hid, data: &[u8], ) -> Self::WriteSocketResponseFut

fn read_socket_streaming_start( &self, handle: &Hid, ) -> Self::ReadSocketStreamingStartResponseFut

fn read_socket_streaming_stop( &self, handle: &Hid, ) -> Self::ReadSocketStreamingStopResponseFut

Implementors

impl SocketProxyInterface for SocketProxy

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

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

type ReadSocketResponseFut = QueryResponseFut<Result<Vec<u8>, Error>>

type WriteSocketResponseFut = QueryResponseFut<Result<u64, WriteSocketError>>

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

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