rx_core_observable_create 0.2.1

create observable for rx_core
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

use rx_core_common::{Signal, Subscriber};

use crate::observable::CreateObservable;

pub fn create_observable<Out, OutError, Producer>(
	producer: Producer,
) -> CreateObservable<Producer, Out, OutError>
where
	Out: Signal,
	OutError: Signal,
	Producer: Clone + FnOnce(&mut dyn Subscriber<In = Out, InError = OutError>),
{
	CreateObservable::new(producer)
}