Trait ConnectedSource

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

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

Required Associated Types§

Source

type Output: Send

Source

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

Required Methods§

Source

fn into_source(self) -> Self::Stream

Implementors§