Control.Observable

Documentation

type Observable f a r = ContT r (Capture r f) a

Capture used here as delimiter

(*=>) :: Monad f => f a -> (a -> f r) -> f r

Looks like a bind, but it has another semantics

dispatch :: ContT r f a -> Observable f a r

Make continuation to be observable

subscribe :: Applicative f => Observable f a r -> (a -> f r) -> f r

Listen all event from action, forever

notify :: Observable f a r -> (a -> f r) -> f r

Listen only first event, just once

obs :: Monad f => f a -> Observable f a r

Make monadic action to be observable

bypass :: (Monad f, Traversable t) => t a -> (a -> f r) -> f (t r)

Yield all a over some t with callback function