rx_core_common 0.2.2

rx_core's core traits and implementations
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use crate::{Observable, ObservableOutput, ObserverInput};

/// # [Operator]
///
/// Operators transform [Observable]s, giving them new behavior.
///
/// ## Composable Operators
///
/// Operators who just want to wrap the destination in a subscriber can also
/// implement [ComposableOperator][crate::ComposableOperator] instead.
/// Which allows the operator to be composable in addition.
pub trait Operator<'o>: ObserverInput + ObservableOutput {
	type OutObservable<InObservable>: 'o + Observable<Out = Self::Out, OutError = Self::OutError>
	where
		InObservable: 'o + Observable<Out = Self::In, OutError = Self::InError> + Send + Sync;

	fn operate<InObservable>(self, source: InObservable) -> Self::OutObservable<InObservable>
	where
		InObservable: 'o + Observable<Out = Self::In, OutError = Self::InError> + Send + Sync;
}