Trait PacketStreamSinkProxyInterface

Source

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;
}