Trait FallibleBatchFeed 

pub trait FallibleBatchFeed {
    type Error;

    // Required method
    fn next_batch(&mut self) -> Result<Option<TimestampBatch>, Self::Error>;
}

Fallible source of complete timestamp batches.

Required Associated Types

type Error

Required Methods

fn next_batch(&mut self) -> Result<Option<TimestampBatch>, Self::Error>

Return every event at the next timestamp, or None at end of input.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl<F> FallibleBatchFeed for Box<F>

where F: FallibleBatchFeed + ?Sized,

type Error = <F as FallibleBatchFeed>::Error

fn next_batch(&mut self) -> Result<Option<TimestampBatch>, Self::Error>

Implementors

impl<F, I, E> FallibleBatchFeed for EventBatchFeed<F, I>

where F: FnMut() -> Result<Option<I>, E>, I: EventSourceItem,

type Error = EventBatchFeedError<E>

impl<F> FallibleBatchFeed for KWayMergeFeed<F>

where F: FallibleBatchFeed,

type Error = KWayMergeError<<F as FallibleBatchFeed>::Error>