Trait AsCollection 

pub trait AsCollection<'scope, T: Timestamp, C> {
    // Required method
    fn as_collection(self) -> Collection<'scope, T, C>;
}

Conversion to a differential dataflow Collection.

Required Methods

fn as_collection(self) -> Collection<'scope, T, C>

Converts the type to a differential dataflow collection.

Implementations on Foreign Types

impl<'scope, T: Timestamp, C> AsCollection<'scope, T, C> for Stream<'scope, T, C>

fn as_collection(self) -> Collection<'scope, T, C>

Converts the type to a differential dataflow collection.

By calling this method, you guarantee that the timestamp invariant (as documented on Collection) is upheld. This method will not check it.

Implementors