Trait ConnectedSource 

pub trait ConnectedSource {
    type Output: Send;
    type Stream: Stream<Item = Result<Self::Output, Error>> + Send + Sync;

    // Required method
    fn into_source(self) -> Self::Stream;
}

Available on crate feature deploy_integration only.

Required Associated Types

type Output: Send

type Stream: Stream<Item = Result<Self::Output, Error>> + Send + Sync

Required Methods

fn into_source(self) -> Self::Stream

Implementors

impl ConnectedSource for ConnectedDirect

type Output = BytesMut

type Stream = Pin<Box<dyn Stream<Item = Result<BytesMut, Error>> + Send + Sync>>

impl<T> ConnectedSource for ConnectedTagged<T>

where T: ConnectedSource, <T as ConnectedSource>::Output: 'static + Sync + Unpin,

type Output = (u32, <T as ConnectedSource>::Output)

type Stream = MergeSource<Result<<ConnectedTagged<T> as ConnectedSource>::Output, Error>, TaggedSource<<T as ConnectedSource>::Output, <T as ConnectedSource>::Stream>>