Struct FlattenInnerObserver 

pub struct FlattenInnerObserver<O, S, St> { /* private fields */ }

This is an Observer for items of an Observable that is emitted from a parent Observable.

Trait Implementations

impl<O: Clone, S: Clone, St: Clone> Clone for FlattenInnerObserver<O, S, St>

fn clone(&self) -> FlattenInnerObserver<O, S, St>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<O, S, Item, Err> Observer for FlattenInnerObserver<O, S, Arc<Mutex<FlattenState>>>

where O: Observer<Item = Item, Err = Err>, S: SubscriptionLike,

type Item = Item

type Err = Err

fn next(&mut self, item: Self::Item)

fn error(&mut self, err: Self::Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<O, S, Item, Err> Observer for FlattenInnerObserver<O, S, Box<FlattenState>>

where O: Observer<Item = Item, Err = Err>, S: SubscriptionLike,

type Item = Item

type Err = Err

fn next(&mut self, item: Self::Item)

fn error(&mut self, err: Self::Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool

impl<O, S, Item, Err> Observer for FlattenInnerObserver<O, S, Rc<RefCell<FlattenState>>>

where O: Observer<Item = Item, Err = Err>, S: SubscriptionLike,

type Item = Item

type Err = Err

fn next(&mut self, item: Self::Item)

fn error(&mut self, err: Self::Err)

fn complete(&mut self)

fn is_stopped(&self) -> bool