pub enum AggregationStatus<Aggregated> {
Ignore,
Aggregated(Aggregated),
}
Expand description
Status of merging multiple messages into one Aggregated
Variants§
Ignore
The merge is incomplete, need more incoming messages.
Aggregated(Aggregated)
For the first time, the multiple input messages are merged into one.
Auto Trait Implementations§
impl<Aggregated> Freeze for AggregationStatus<Aggregated>where
Aggregated: Freeze,
impl<Aggregated> RefUnwindSafe for AggregationStatus<Aggregated>where
Aggregated: RefUnwindSafe,
impl<Aggregated> Send for AggregationStatus<Aggregated>where
Aggregated: Send,
impl<Aggregated> Sync for AggregationStatus<Aggregated>where
Aggregated: Sync,
impl<Aggregated> Unpin for AggregationStatus<Aggregated>where
Aggregated: Unpin,
impl<Aggregated> UnwindSafe for AggregationStatus<Aggregated>where
Aggregated: UnwindSafe,
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more