Struct OperatorWrapper 

pub struct OperatorWrapper<O: BaseOperator> {
    pub waker: Arc<CountingWaker>,
    pub operator: O,
}

Wrapper around an operator that provides extra utilities to reduce boiler plate.

All poll_ helper method currently shared the same counting waker.

Fields

waker: Arc<CountingWaker>

operator: O

Implementations

impl<O> OperatorWrapper<O>

where O: BaseOperator,

pub fn new(operator: O) -> Self

impl<O> OperatorWrapper<O>

where O: ExecuteOperator,

pub fn poll_execute( &self, operator_state: &O::OperatorState, state: &mut O::PartitionExecuteState, input: &mut Batch, output: &mut Batch, ) -> Result<PollExecute>

pub fn poll_finalize_execute( &self, operator_state: &O::OperatorState, state: &mut O::PartitionExecuteState, ) -> Result<PollFinalize>

impl<O> OperatorWrapper<O>

where O: PullOperator,

pub fn poll_pull( &self, operator_state: &O::OperatorState, state: &mut O::PartitionPullState, output: &mut Batch, ) -> Result<PollPull>

impl<O> OperatorWrapper<O>

where O: PushOperator,

pub fn poll_push( &self, operator_state: &O::OperatorState, state: &mut O::PartitionPushState, input: &mut Batch, ) -> Result<PollPush>

pub fn poll_finalize_push( &self, operator_state: &O::OperatorState, state: &mut O::PartitionPushState, ) -> Result<PollFinalize>