Enum tinychain::stream::TCStream

pub enum TCStream {
    Aggregate(Box<TCStream>),
    Collection(Collection),
    Map(Box<TCStream>, Closure),
}

Variants

Aggregate

Tuple Fields of Aggregate

0: Box<TCStream>

Collection

Tuple Fields of Collection

0: Collection

Map

Tuple Fields of Map

0: Box<TCStream>1: Closure

Implementations

impl TCStream

pub fn aggregate(self) -> Self

pub async fn fold(self, txn: Txn, value: Value, op: Closure) -> TCResult<Value>

pub async fn for_each(self, txn: &Txn, op: Closure) -> TCResult<()>

pub fn map(self, op: Closure) -> Self

pub fn into_stream<'a>(
    self,
    txn: Txn
) -> TCBoxTryFuture<'a, TCBoxTryStream<'static, State>>

Trait Implementations

impl Clone for TCStream

fn clone(&self) -> TCStream

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> From<T> for TCStream where
    Collection: From<T>, 

fn from(collection: T) -> Self

Performs the conversion.

impl From<TCStream> for State

fn from(stream: TCStream) -> Self

Performs the conversion.

impl TryCastFrom<State> for TCStream

fn can_cast_from(state: &State) -> bool

Test if value can be cast into Self.

fn opt_cast_from(state: State) -> Option<Self>

Returns Some(Self) if the source value can be cast into Self, otherwise None.

fn try_cast_from<Err, OnErr>(value: T, on_err: OnErr) -> Result<Self, Err> where
    OnErr: FnOnce(&T) -> Err, 

Returns Ok(Self) if the source value can be cast into Self, otherwise calls on_err.