Struct fp_rust::monadio::MonadIO [−][src]
pub struct MonadIO<Y> { /* fields omitted */ }MonadIO implements basic Rx/MonadIO APIs.
The observe and subscribe actions could be sync/async,
and observe & subscribe could be on other threads
(by setting up observe_on and subscribe_on).
Arguments
Y- The generic type of data
Remarks
It's inspired by Rx & MonadIO in Haskell
, and easily run it on sync/async scenaios.
``
Methods
impl<Y: 'static + Send + Sync + Clone> MonadIO<Y>[src]
impl<Y: 'static + Send + Sync + Clone> MonadIO<Y>pub fn just(r: Y) -> MonadIO<Y>[src]
pub fn just(r: Y) -> MonadIO<Y>pub fn new(
effect: impl FnMut() -> Y + Send + Sync + 'static
) -> MonadIO<Y>[src]
pub fn new(
effect: impl FnMut() -> Y + Send + Sync + 'static
) -> MonadIO<Y>pub fn new_with_handlers(
effect: impl FnMut() -> Y + Send + Sync + 'static,
ob: Option<Arc<Mutex<Handler + 'static>>>,
sub: Option<Arc<Mutex<Handler + 'static>>>
) -> MonadIO<Y>[src]
pub fn new_with_handlers(
effect: impl FnMut() -> Y + Send + Sync + 'static,
ob: Option<Arc<Mutex<Handler + 'static>>>,
sub: Option<Arc<Mutex<Handler + 'static>>>
) -> MonadIO<Y>pub fn observe_on(&mut self, h: Option<Arc<Mutex<Handler + 'static>>>)[src]
pub fn observe_on(&mut self, h: Option<Arc<Mutex<Handler + 'static>>>)pub fn subscribe_on(&mut self, h: Option<Arc<Mutex<Handler + 'static>>>)[src]
pub fn subscribe_on(&mut self, h: Option<Arc<Mutex<Handler + 'static>>>)pub fn map<Z: 'static + Send + Sync + Clone>(
&self,
func: impl FnMut(Y) -> Z + Send + Sync + 'static + Clone
) -> MonadIO<Z>[src]
pub fn map<Z: 'static + Send + Sync + Clone>(
&self,
func: impl FnMut(Y) -> Z + Send + Sync + 'static + Clone
) -> MonadIO<Z>pub fn fmap<Z: 'static + Send + Sync + Clone>(
&self,
func: impl FnMut(Y) -> MonadIO<Z> + Send + Sync + 'static + Clone
) -> MonadIO<Z>[src]
pub fn fmap<Z: 'static + Send + Sync + Clone>(
&self,
func: impl FnMut(Y) -> MonadIO<Z> + Send + Sync + 'static + Clone
) -> MonadIO<Z>pub fn subscribe(
&self,
s: Arc<impl Subscription<Y> + Clone>
)[src]
pub fn subscribe(
&self,
s: Arc<impl Subscription<Y> + Clone>
)pub fn subscribe_fn(
&self,
func: impl FnMut(Arc<Y>) + Send + Sync + 'static + Clone
)[src]
pub fn subscribe_fn(
&self,
func: impl FnMut(Arc<Y>) + Send + Sync + 'static + Clone
)