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

use crate::{ErasedObservable, Observable};

pub trait EraseObservableExtension<O>
where
	O: 'static + Observable + Send + Sync,
{
	fn erase(self) -> ErasedObservable<O::Out, O::OutError>;
}

impl<O> EraseObservableExtension<O> for O
where
	O: 'static + Observable + Send + Sync,
{
	#[inline]
	fn erase(self) -> ErasedObservable<<O>::Out, <O>::OutError> {
		ErasedObservable::new(self)
	}
}