Struct VecSink 

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

A sink that collects items into a vector.

Implementations

impl<T> VecSink<T>

pub fn new() -> Self

pub fn with_capacity(capacity: usize) -> Self

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

Consume the sink and return collected items.

pub fn items(&self) -> &[T]

Get a reference to collected items.

Trait Implementations

impl<T> Default for VecSink<T>

fn default() -> Self

Returns the “default value” for a type.

impl<T> Sink for VecSink<T>

type Item = T

The type of items this sink accepts.

fn write(&mut self, item: Self::Item) -> Result<(), SynthError>

Write a single item to the sink.

fn write_batch(&mut self, items: Vec<Self::Item>) -> Result<(), SynthError>

Write a batch of items to the sink.

fn flush(&mut self) -> Result<(), SynthError>

Flush any buffered data to the destination.

fn close(self) -> Result<(), SynthError>

Close the sink and release resources.

fn items_written(&self) -> u64

Get the number of items written.

fn bytes_written(&self) -> Option<u64>

Get the number of bytes written (if applicable).