Trait timely::dataflow::stream::AsStream

pub trait AsStream<S: Scope, C> {
    // Required method
    fn as_stream(self) -> StreamCore<S, C>;
}

A type that can be translated to a StreamCore.

Required Methods

fn as_stream(self) -> StreamCore<S, C>

Translate self to a StreamCore.

Implementors

impl<S: Scope, C> AsStream<S, C> for StreamCore<S, C>