Trait hydroflow::util::deploy::ConnectedSink

pub trait ConnectedSink {
    type Input: Send;
    type Sink: Sink<Self::Input, Error = Error> + Send + Sync;

    // Required method
    fn into_sink(self) -> Self::Sink;
}

Required Associated Types

type Input: Send

type Sink: Sink<Self::Input, Error = Error> + Send + Sync

Required Methods

fn into_sink(self) -> Self::Sink

Implementors

impl ConnectedSink for ConnectedDirect

type Input = Bytes

type Sink = Pin<Box<dyn Sink<Bytes, Error = Error> + Sync + Send>>

impl<T> ConnectedSink for ConnectedDemux<T>

where T: ConnectedSink, <T as ConnectedSink>::Input: 'static + Sync,

type Input = (u32, <T as ConnectedSink>::Input)

type Sink = DemuxDrain<<T as ConnectedSink>::Input, Buffer<<T as ConnectedSink>::Sink, <T as ConnectedSink>::Input>>