Struct GroupByObserver 

pub struct GroupByObserver<Obs, Source, Discr, Key, Item> { /* private fields */ }

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<Obs: Clone, Source: Clone, Discr: Clone, Key: Clone, Item: Clone> Clone for GroupByObserver<Obs, Source, Discr, Key, Item>

fn clone(&self) -> GroupByObserver<Obs, Source, Discr, Key, Item>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

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,

type Item = Item

type Err = Err

fn next(&mut self, value: Item)

fn error(&mut self, err: Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool