Trait reactor_rs::prelude::Subscriber

pub trait Subscriber {
    type Item;
    type Error;
    fn on_complete(&self);
    fn on_next(&self, t: Self::Item)
    where
        Self: Sized;
    fn on_subscribe(&self, subscription: impl Subscription)
    where
        Self: Sized;
    fn on_error(&self, e: Self::Error)
    where
        Self: Sized;
}

Associated Types

type Item

type Error

Loading content...

Required methods

fn on_complete(&self)

fn on_next(&self, t: Self::Item) where
    Self: Sized, 

fn on_subscribe(&self, subscription: impl Subscription) where
    Self: Sized, 

fn on_error(&self, e: Self::Error) where
    Self: Sized, 

Loading content...

Implementors

Loading content...