Enum dataflow::source::NextMessage [−][src]
pub(crate) enum NextMessage<Key, Value> {
Ready(SourceMessage<Key, Value>),
Pending,
TransientDelay,
Finished,
}
Variants
Ready(SourceMessage<Key, Value>)
Tuple Fields
0: SourceMessage<Key, Value>
Pending
TransientDelay
Finished
Auto Trait Implementations
impl<Key, Value> RefUnwindSafe for NextMessage<Key, Value> where
Key: RefUnwindSafe,
Value: RefUnwindSafe,
impl<Key, Value> Send for NextMessage<Key, Value> where
Key: Send,
Value: Send,
impl<Key, Value> Sync for NextMessage<Key, Value> where
Key: Sync,
Value: Sync,
impl<Key, Value> Unpin for NextMessage<Key, Value> where
Key: Unpin,
Value: Unpin,
impl<Key, Value> UnwindSafe for NextMessage<Key, Value> where
Key: UnwindSafe,
Value: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more