Struct rxrust::ops::skip_while::SkipWhileObserver

pub struct SkipWhileObserver<O, F> { /* private fields */ }

Trait Implementations

impl<O, Item, Err, F> Observer<Item, Err> for SkipWhileObserver<O, F>where O: Observer<Item, Err>, F: FnMut(&Item) -> bool,

fn next(&mut self, value: Item)

fn error(self, err: Err)

fn complete(self)

fn is_finished(&self) -> bool

return if the observer is finished, that means the observer can emit value or not. false can, true not.