Struct another_rxrust::observable::Observable

pub struct Observable<'a, Item>where
    Item: Clone + Send + Sync,{ /* private fields */ }

Implementations

impl<'a, Item> Observable<'a, Item>where Item: Clone + Send + Sync,

pub fn create<Source>(source: Source) -> Observable<'a, Item>where Source: Fn(Observer<'a, Item>) + Send + Sync + 'a,

pub fn subscribe<Next, Error, Complete>( &self, next: Next, error: Error, complete: Complete ) -> Subscription<'_>where Next: Fn(Item) + Send + Sync + 'a, Error: Fn(RxError) + Send + Sync + 'a, Complete: Fn() + Send + Sync + 'a,

pub fn map<Out, F>(&self, f: F) -> Observable<'a, Out>where F: Fn(Item) -> Out + Send + Sync + 'a, Out: Clone + Send + Sync,

pub fn flat_map<Out, F>(&self, f: F) -> Observable<'a, Out>where F: Fn(Item) -> Observable<'a, Out> + Send + Sync + 'a, Out: Clone + Send + Sync,

pub fn on_error_resume_next<F>(&self, f: F) -> Observable<'a, Item>where F: Fn(RxError) -> Observable<'a, Item> + Send + Sync + 'a,

pub fn observe_on<Scheduler, SchedulerCreator>( &self, scheduler_ctor: SchedulerCreator ) -> Observable<'a, Item>where Scheduler: IScheduler<'a> + Clone + Send + Sync + 'a, SchedulerCreator: Fn() -> Scheduler + Send + Sync + 'a,

pub fn subscribe_on<Scheduler, SchedulerCreator>( &self, scheduler_ctor: SchedulerCreator ) -> Observable<'a, Item>where Scheduler: IScheduler<'a> + Clone + Send + Sync + 'a, SchedulerCreator: Fn() -> Scheduler + Send + Sync + 'a,

pub fn take(&self, count: usize) -> Observable<'a, Item>

pub fn take_last(&self, count: usize) -> Observable<'a, Item>

pub fn first(&self) -> Observable<'a, Item>

pub fn last(&self) -> Observable<'a, Item>

pub fn skip(&self, count: usize) -> Observable<'a, Item>

pub fn skip_last(&self, count: usize) -> Observable<'a, Item>

pub fn take_until<TriggerValue>( &self, trigger: Observable<'a, TriggerValue> ) -> Observable<'a, Item>where TriggerValue: Clone + Send + Sync,

pub fn skip_until<TriggerValue>( &self, trigger: Observable<'a, TriggerValue> ) -> Observable<'a, Item>where TriggerValue: Clone + Send + Sync,

pub fn take_while<F>(&self, f: F) -> Observable<'a, Item>where F: Fn(Item) -> bool + Send + Sync + 'a,

pub fn skip_while<F>(&self, f: F) -> Observable<'a, Item>where F: Fn(Item) -> bool + Send + Sync + 'a,

pub fn tap<Next, Error, Complete>( &self, next: Next, error: Error, complete: Complete ) -> Observable<'a, Item>where Next: Fn(Item) + Send + Sync + 'a, Error: Fn(RxError) + Send + Sync + 'a, Complete: Fn() + Send + Sync + 'a,

pub fn retry(&self, max_retry: usize) -> Observable<'a, Item>

pub fn retry_when<F>(&self, f: F) -> Observable<'a, Item>where F: Fn(RxError) -> bool + Send + Sync + 'a,

pub fn merge( &self, observables: &[Observable<'a, Item>] ) -> Observable<'a, Item>

pub fn amb(&self, observables: &[Observable<'a, Item>]) -> Observable<'a, Item>

pub fn pipe<F, Out>(&self, f: F) -> Observable<'a, Out>where Out: Clone + Send + Sync, F: Fn(Observable<'_, Item>) -> Observable<'_, Out>,

pub fn start_with<Iter>(&self, iter: Iter) -> Observable<'a, Item>where Iter: Iterator<Item = Item> + Clone + Send + Sync + 'a,

impl<'a, Item> Observable<'a, Item>where Item: Clone + Send + Sync + PartialEq,

pub fn distinct_until_changed(&self) -> Observable<'a, Item>

Trait Implementations

impl<'a, Item> Clone for Observable<'a, Item>where Item: Clone + Send + Sync + Clone,

fn clone(&self) -> Observable<'a, Item>

Returns a copy of the value.

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

Performs copy-assignment from source.