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

use crate::{Observable, Operator};

pub trait ObservablePipeExtensionPipe: Observable + Sized + Send + Sync {
	fn pipe<'o, Op>(self, operator: Op) -> <Op as Operator<'o>>::OutObservable<Self>
	where
		Self: Sized,
		Op: Operator<'o, In = Self::Out, InError = Self::OutError>,
	{
		operator.operate(self)
	}
}

impl<O> ObservablePipeExtensionPipe for O where O: Observable + Send + Sync {}