[−][src]Trait reactor_rs::prelude::Publisher
Associated Types
Loading content...Required methods
fn subscribe(
self,
subscriber: impl Subscriber<Item = Self::Item, Error = Self::Error> + 'static + Send
) where
Self: Sized,
self,
subscriber: impl Subscriber<Item = Self::Item, Error = Self::Error> + 'static + Send
) where
Self: Sized,
Implementors
impl<E> Publisher for MonoError<E>
[src]
type Item = ()
type Error = E
fn subscribe(self, subscriber: impl Subscriber<Item = (), Error = E>)
[src]
impl<M, T, F, E> Publisher for MonoFilter<M, T, F, E> where
M: Mono<T, E> + Sized,
F: 'static + Send + Fn(&T) -> bool,
[src]
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
)
[src]
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,
[src]
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
)
[src]
self,
subscriber: impl Subscriber<Item = T2, Error = E> + 'static + Send
)
impl<T, E> Publisher for MonoJust<T, E> where
T: Clone,
[src]
T: Clone,
type Item = T
type Error = E
fn subscribe(self, subscriber: impl Subscriber<Item = T, Error = E>)
[src]
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,
[src]
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
)
[src]
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(),
[src]
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
)
[src]
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(),
[src]
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
)
[src]
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),
[src]
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
)
[src]
self,
subscriber: impl Subscriber<Item = T, Error = E> + 'static + Send
)
impl<T, G> Publisher for MonoCreateSuccess<T, G> where
G: Fn() -> T,
[src]
G: Fn() -> T,
type Item = T
type Error = ()
fn subscribe(self, subscriber: impl Subscriber<Item = T, Error = ()>)
[src]
impl<T, G, E> Publisher for MonoCreate<T, G, E> where
G: Fn() -> Result<T, E>,
[src]
G: Fn() -> Result<T, E>,
type Item = T
type Error = E
fn subscribe(self, subscriber: impl Subscriber<Item = T, Error = E>)
[src]
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,
[src]
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
)
[src]
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),
[src]
Z: Mono<T, E> + Sized,
F: 'static + Send + Fn(&T),