Trait reactor_rs::prelude::Publisher

pub trait Publisher {
    type Item;
    type Error;
    fn subscribe(
        self, 
        subscriber: impl Subscriber<Item = Self::Item, Error = Self::Error> + 'static + Send
    )
    where
        Self: Sized;
}

Associated Types

type Item

type Error

Loading content...

Required methods

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = Self::Item, Error = Self::Error> + 'static + Send
) where
    Self: Sized, 

Loading content...

Implementors

impl<E> Publisher for MonoError<E>

type Item = ()

type Error = E

fn subscribe(self, subscriber: impl Subscriber<Item = (), Error = E>)

impl<M, T, F, E> Publisher for MonoFilter<M, T, F, E> where
    M: Mono<T, E> + Sized,
    F: 'static + Send + Fn(&T) -> bool, 

type Item = T

type Error = E

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = T, Error = E> + 'static + Send
)

impl<M, T1, T2, F, E> Publisher for MonoTransform<M, T1, T2, F, E> where
    T1: Send,
    T2: Send,
    M: Mono<T1, E> + Sized,
    F: 'static + Send + Fn(T1) -> T2, 

type Item = T2

type Error = E

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = T2, Error = E> + 'static + Send
)

impl<T, E> Publisher for MonoJust<T, E> where
    T: Clone, 

type Item = T

type Error = E

fn subscribe(self, subscriber: impl Subscriber<Item = T, Error = E>)

impl<T, E, M, C> Publisher for MonoScheduleOn<T, E, M, C> where
    M: 'static + Send + Mono<T, E> + Sized,
    C: Scheduler<Item = T, Error = E> + Sized, 

type Item = T

type Error = E

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = T, Error = E> + 'static + Send
)

impl<T, E, M, F> Publisher for MonoDoFinally<T, E, M, F> where
    M: Mono<T, E>,
    F: 'static + Send + Fn(), 

type Item = T

type Error = E

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = T, Error = E> + 'static + Send
)

impl<T, E, M, F> Publisher for MonoDoOnComplete<T, E, M, F> where
    M: Mono<T, E>,
    F: 'static + Send + Fn(), 

type Item = T

type Error = E

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = T, Error = E> + 'static + Send
)

impl<T, E, M, F> Publisher for MonoDoOnError<T, E, M, F> where
    M: Mono<T, E> + Sized,
    F: 'static + Send + Fn(&E), 

type Item = T

type Error = E

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = T, Error = E> + 'static + Send
)

impl<T, G> Publisher for MonoCreateSuccess<T, G> where
    G: Fn() -> T, 

type Item = T

type Error = ()

fn subscribe(self, subscriber: impl Subscriber<Item = T, Error = ()>)

impl<T, G, E> Publisher for MonoCreate<T, G, E> where
    G: Fn() -> Result<T, E>, 

type Item = T

type Error = E

fn subscribe(self, subscriber: impl Subscriber<Item = T, Error = E>)

impl<T1, T2, E, M1, M2, F> Publisher for MonoFlatMap<T1, T2, E, M1, M2, F> where
    T1: 'static + Send,
    T2: 'static + Send,
    E: 'static + Send,
    M1: 'static + Send + Mono<T1, E>,
    M2: 'static + Send + Mono<T2, E>,
    F: 'static + Send + Fn(T1) -> M2, 

type Item = T2

type Error = E

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = T2, Error = E> + 'static + Send
)

impl<Z, T, F, E> Publisher for Foreach<Z, T, F, E> where
    Z: Mono<T, E> + Sized,
    F: 'static + Send + Fn(&T), 

type Item = T

type Error = E

fn subscribe(
    self,
    subscriber: impl Subscriber<Item = T, Error = E> + 'static + Send
)

Loading content...