Struct CollectSink 

pub struct CollectSink<T> { /* private fields */ }

Sink that collects all items into a Vec<T>.

After the pipeline completes, call into_vec() to retrieve the collected items.

Example

use grafos_stream::sink::CollectSink;
use grafos_stream::stage::Sink;

let mut sink = CollectSink::new();
sink.accept(1).unwrap();
sink.accept(2).unwrap();
assert_eq!(sink.into_vec(), vec![1, 2]);

Implementations

impl<T> CollectSink<T>

pub fn new() -> Self

Create an empty collecting sink.

pub fn into_vec(self) -> Vec<T>

Consume the sink and return all accepted items in arrival order.

Trait Implementations

impl<T> Default for CollectSink<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Sink<T> for CollectSink<T>

fn accept(&mut self, item: T) -> Result<(), FabricError>