Trait UnixDomainSocketProxyInterface

pub trait UnixDomainSocketProxyInterface: Send + Sync {
    type CloseResponseFut: Future<Output = Result<CloseableCloseResult, Error>> + Send;
    type QueryResponseFut: Future<Output = Result<Vec<u8>, Error>> + Send;
    type GetEventResponseFut: Future<Output = Result<UnixDomainSocketGetEventResult, Error>> + Send;
    type ReadResponseFut: Future<Output = Result<UnixDomainSocketReadResult, Error>> + Send;
    type WriteResponseFut: Future<Output = Result<UnixDomainSocketWriteResult, Error>> + Send;

    // Required methods
    fn clone(&self, request: ServerEnd<CloneableMarker>) -> Result<(), Error>;
    fn close(&self) -> Self::CloseResponseFut;
    fn query(&self) -> Self::QueryResponseFut;
    fn get_event(
        &self,
        payload: &UnixDomainSocketGetEventRequest,
    ) -> Self::GetEventResponseFut;
    fn read(
        &self,
        payload: &UnixDomainSocketReadRequest,
    ) -> Self::ReadResponseFut;
    fn write(
        &self,
        payload: UnixDomainSocketWriteRequest,
    ) -> Self::WriteResponseFut;
}

Required Associated Types

type CloseResponseFut: Future<Output = Result<CloseableCloseResult, Error>> + Send

type QueryResponseFut: Future<Output = Result<Vec<u8>, Error>> + Send

type GetEventResponseFut: Future<Output = Result<UnixDomainSocketGetEventResult, Error>> + Send

type ReadResponseFut: Future<Output = Result<UnixDomainSocketReadResult, Error>> + Send

type WriteResponseFut: Future<Output = Result<UnixDomainSocketWriteResult, Error>> + Send

Required Methods

fn clone(&self, request: ServerEnd<CloneableMarker>) -> Result<(), Error>

fn close(&self) -> Self::CloseResponseFut

fn query(&self) -> Self::QueryResponseFut

fn get_event( &self, payload: &UnixDomainSocketGetEventRequest, ) -> Self::GetEventResponseFut

fn read(&self, payload: &UnixDomainSocketReadRequest) -> Self::ReadResponseFut

fn write(&self, payload: UnixDomainSocketWriteRequest) -> Self::WriteResponseFut

Implementors

impl UnixDomainSocketProxyInterface for UnixDomainSocketProxy

type CloseResponseFut = QueryResponseFut<Result<(), i32>>

type QueryResponseFut = QueryResponseFut<Vec<u8>>

type GetEventResponseFut = QueryResponseFut<Result<UnixDomainSocketGetEventResponse, i32>>

type ReadResponseFut = QueryResponseFut<Result<UnixDomainSocketReadResponse, i32>>

type WriteResponseFut = QueryResponseFut<Result<UnixDomainSocketWriteResponse, i32>>