Trait Consume

pub trait Consume<T> {
    type Error: From<ConnectorXError> + Send;

    // Required method
    fn consume(&mut self, value: T) -> Result<(), Self::Error>;
}

A type implemented Consume<T> means that it can consume a value T by adding it to it’s own buffer.

Required Associated Types

type Error: From<ConnectorXError> + Send

Required Methods

fn consume(&mut self, value: T) -> Result<(), Self::Error>

Implementors

impl<'a, T> Consume<T> for connectorx::destinations::arrow2::ArrowPartitionWriter

where T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,

type Error = Arrow2DestinationError

impl<'a, T> Consume<T> for connectorx::destinations::arrow::ArrowPartitionWriter

where T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,

type Error = ArrowDestinationError

impl<'a, T> Consume<T> for connectorx::destinations::arrowstream::ArrowPartitionWriter

where T: TypeAssoc<<Self as DestinationPartition<'a>>::TypeSystem> + ArrowAssoc + 'static,

type Error = ArrowDestinationError