Trait tinychain::stream::Source

source · [−]

pub trait Source: Clone + Sized where
    TCStream: From<Self>, {
    fn into_stream<'async_trait>(
        self, 
        txn: Txn
    ) -> Pin<Box<dyn Future<Output = TCResult<TCBoxTryStream<'static, State>>> + Send + 'async_trait>>
    where
        Self: 'async_trait;
}

Expand description

Trait defining the source of a [Stream].

Required Methods

fn into_stream<'async_trait>(
    self,
    txn: Txn
) -> Pin<Box<dyn Future<Output = TCResult<TCBoxTryStream<'static, State>>> + Send + 'async_trait>> where
    Self: 'async_trait,

Implementors

impl Source for TCStream