Struct rxrust::subscriber::Subscriber

pub struct Subscriber<Sub> { /* fields omitted */ }

Implements the Observer trait and Subscription trait. While the Observer is the public API for consuming the values of an Observable, all Observers get converted to a Subscriber, in order to provide Subscription capabilities.

Methods

impl<Sub> Subscriber<Sub>

pub fn new(subscribe: Sub) -> Self

pub fn clone_subscription(&self) -> SimpleSubscription

Trait Implementations

impl<Sub> Subscription for Subscriber<Sub>

fn unsubscribe(&mut self)

This allows deregistering an stream before it has finished receiving all events (i.e. before onCompleted is called).

impl<Item, Err, Sub> Observer<Item, Err> for Subscriber<Sub> where
    Sub: RxFn(RxValue<&Item, &Err>), 

fn next(&self, v: &Item)

fn complete(&mut self)

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

fn is_stopped(&self) -> bool

impl<Sub> Sync for Subscriber<Sub> where
    Sub: Send, 

impl<Sub> Send for Subscriber<Sub> where
    Sub: Send,