Trait PacketStreamSinkProxyInterface 

pub trait PacketStreamSinkProxyInterface: Send + Sync {
    type PutPacketResponseFut: Future<Output = Result<PacketStreamSinkPutPacketResult, Error>> + Send;
    type FlushPacketsResponseFut: Future<Output = Result<PacketStreamSinkFlushPacketsResult, Error>> + Send;

    // Required methods
    fn put_packet(
        &self,
        payload: PacketStreamSinkPutPacketRequest,
    ) -> Self::PutPacketResponseFut;
    fn flush_packets(&self) -> Self::FlushPacketsResponseFut;
}

Required Associated Types

type PutPacketResponseFut: Future<Output = Result<PacketStreamSinkPutPacketResult, Error>> + Send

type FlushPacketsResponseFut: Future<Output = Result<PacketStreamSinkFlushPacketsResult, Error>> + Send

Required Methods

fn put_packet( &self, payload: PacketStreamSinkPutPacketRequest, ) -> Self::PutPacketResponseFut

fn flush_packets(&self) -> Self::FlushPacketsResponseFut

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl PacketStreamSinkProxyInterface for PacketStreamSinkProxy

type PutPacketResponseFut = QueryResponseFut<Result<PacketStreamSinkPutPacketResponse, i32>>

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