Struct TransformSourceWithOperator 

pub struct TransformSourceWithOperator<T, R>
where
    T: Clone,
    R: Clone,
{ /* private fields */ }

A source that applies a single operator transformation

Implementations

impl<T, R> TransformSourceWithOperator<T, R>

where T: Clone + Send + Sync + 'static, R: Clone + Send + Sync + 'static,

pub fn new<O>( inner: Arc<InnerSource<T>>, operator: O, operators: Vec<Arc<InnerOperator<T, T>>>, ) -> Self

where O: Operator<T, R> + Send + Sync + 'static,

Trait Implementations

impl<T, R> Clone for TransformSourceWithOperator<T, R>

where T: Clone + Clone, R: Clone + Clone,

fn clone(&self) -> TransformSourceWithOperator<T, R>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T, R> Source<R> for TransformSourceWithOperator<T, R>

where T: Clone + Send + Sync + 'static, R: Clone + Send + Sync + 'static,

fn init<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Initialize the source

fn next<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<Option<Record<R>>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read the next record from the source

fn close<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Close the source and release resources