pub struct OneInTwoOutContext<'a, S, T, U> where
S: State,
T: Data + for<'b> Deserialize<'b>,
U: Data + for<'b> Deserialize<'b>, { /* private fields */ }
Expand description
A context structure made available to the callbacks of a OneInTwoOut
operator. The context
provides access to the current timestamp for which the callback is invoked along with the
state of the operator and the write streams to send the outputs on.
Implementations
sourceimpl<'a, S, T, U> OneInTwoOutContext<'a, S, T, U> where
S: State,
T: Data + for<'b> Deserialize<'b>,
U: Data + for<'b> Deserialize<'b>,
impl<'a, S, T, U> OneInTwoOutContext<'a, S, T, U> where
S: State,
T: Data + for<'b> Deserialize<'b>,
U: Data + for<'b> Deserialize<'b>,
pub fn new(
timestamp: Timestamp,
config: OperatorConfig,
state: &'a mut S,
left_write_stream: WriteStream<T>,
right_write_stream: WriteStream<U>
) -> Self
sourcepub fn operator_config(&self) -> &OperatorConfig
pub fn operator_config(&self) -> &OperatorConfig
Get the configuration of the operator.
sourcepub fn current_state(&mut self) -> Option<&mut S::Item>
pub fn current_state(&mut self) -> Option<&mut S::Item>
Get the current state attached to the operator.
sourcepub fn past_state(&mut self, time: &Timestamp) -> Option<&S::Item>
pub fn past_state(&mut self, time: &Timestamp) -> Option<&S::Item>
Get the past state attached to the operator.
sourcepub fn last_committed_timestamp(&self) -> Timestamp
pub fn last_committed_timestamp(&self) -> Timestamp
Get the timestamp of the last committed state.
sourcepub fn left_write_stream(&mut self) -> &mut WriteStream<T>
pub fn left_write_stream(&mut self) -> &mut WriteStream<T>
Get the left write stream to send the output on.
sourcepub fn right_write_stream(&mut self) -> &mut WriteStream<U>
pub fn right_write_stream(&mut self) -> &mut WriteStream<U>
Get the right write stream to send the output on.
Auto Trait Implementations
impl<'a, S, T, U> !RefUnwindSafe for OneInTwoOutContext<'a, S, T, U>
impl<'a, S, T, U> Send for OneInTwoOutContext<'a, S, T, U>
impl<'a, S, T, U> Sync for OneInTwoOutContext<'a, S, T, U>
impl<'a, S, T, U> Unpin for OneInTwoOutContext<'a, S, T, U>
impl<'a, S, T, U> !UnwindSafe for OneInTwoOutContext<'a, S, T, U>
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
sourceimpl<T> Instrument for T
impl<T> Instrument for T
sourcefn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
sourcefn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
sourceimpl<T> WithSubscriber for T
impl<T> WithSubscriber for T
sourcefn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
sourcefn with_current_subscriber(self) -> WithDispatch<Self>
fn with_current_subscriber(self) -> WithDispatch<Self>
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more