Struct rxrust::ops::group_by::GroupByObserver [−][src]
pub struct GroupByObserver<Obs, Source, Discr, Key, Item> { /* fields omitted */ }
Expand description
GroupByObserver keeps track of its source observable. Produces GroupObservable objects for each key returned by the discriminator function that was not yet encountered.
Trait Implementations
impl<'a, Obs, Source, Discr, Key, Item, Err> Observer for GroupByObserver<Obs, Source, Discr, Key, Item> where
Obs: Observer<Item = GroupObservable<Source, Discr, Key>, Err = Err>,
Source: Observable + Clone,
Discr: FnMut(&Item) -> Key + Clone,
Key: Hash + Clone + Eq,
impl<'a, Obs, Source, Discr, Key, Item, Err> Observer for GroupByObserver<Obs, Source, Discr, Key, Item> where
Obs: Observer<Item = GroupObservable<Source, Discr, Key>, Err = Err>,
Source: Observable + Clone,
Discr: FnMut(&Item) -> Key + Clone,
Key: Hash + Clone + Eq,
Auto Trait Implementations
impl<Obs, Source, Discr, Key, Item> RefUnwindSafe for GroupByObserver<Obs, Source, Discr, Key, Item> where
Discr: RefUnwindSafe,
Item: RefUnwindSafe,
Key: RefUnwindSafe,
Obs: RefUnwindSafe,
Source: RefUnwindSafe,
impl<Obs, Source, Discr, Key, Item> Send for GroupByObserver<Obs, Source, Discr, Key, Item> where
Discr: Send,
Key: Send,
Obs: Send,
Source: Send,
impl<Obs, Source, Discr, Key, Item> Sync for GroupByObserver<Obs, Source, Discr, Key, Item> where
Discr: Sync,
Key: Sync,
Obs: Sync,
Source: Sync,
impl<Obs, Source, Discr, Key, Item> Unpin for GroupByObserver<Obs, Source, Discr, Key, Item> where
Discr: Unpin,
Key: Unpin,
Obs: Unpin,
Source: Unpin,
impl<Obs, Source, Discr, Key, Item> UnwindSafe for GroupByObserver<Obs, Source, Discr, Key, Item> where
Discr: UnwindSafe,
Item: RefUnwindSafe,
Key: UnwindSafe,
Obs: UnwindSafe,
Source: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more