Rx.Observable

data Observable :: Type -> Type

A type which represents streams of discrete events. Please see RxJS API documentation for more more examples.

Instances

• Functor Observable
• Apply Observable
• Applicative Observable
• Bind Observable
• Monad Observable
• Semigroup (Observable a)
• Alt Observable
• Plus Observable
• Alternative Observable
• MonadZero Observable
• MonadPlus Observable
• MonadError Error Observable
• MonadThrow Error Observable

fromArray :: forall a. Array a -> Observable a

generate :: forall b a. a -> (a -> Boolean) -> (a -> a) -> (a -> b) -> Observable b

subscribe' :: forall a eff. Observable a -> (a -> Eff eff Unit) -> (Error -> Eff eff Unit) -> (Unit -> Eff eff Unit) -> Eff eff Unit

subscribe :: forall a eff. Observable a -> (a -> Eff eff Unit) -> Eff eff Unit

subscribeOnCompleted :: forall a eff. Observable a -> (Unit -> Eff eff Unit) -> Eff eff Unit

subscribeOnError :: forall a eff. Observable a -> (Error -> Eff eff Unit) -> Eff eff Unit

merge :: forall a. Observable a -> Observable a -> Observable a

combineLatest :: forall c b a. (a -> b -> c) -> Observable a -> Observable b -> Observable c

concat :: forall a. Observable a -> Observable a -> Observable a

take :: forall a. Int -> Observable a -> Observable a

takeUntil :: forall b a. Observable b -> Observable a -> Observable a

flatMap :: forall b a. Observable a -> (a -> Observable b) -> Observable b

flatMapLatest :: forall b a. Observable a -> (a -> Observable b) -> Observable b

scan :: forall b a. (a -> b -> b) -> b -> Observable a -> Observable b

startWith :: forall a. a -> Observable a -> Observable a

unwrap :: forall a eff. Observable (Eff eff a) -> Eff eff (Observable a)

runObservable :: forall eff. Observable (Eff eff Unit) -> Eff eff Unit

switchLatest :: forall a. Observable (Observable a) -> Observable a

debounce :: forall a. Int -> Observable a -> Observable a

zip :: forall c b a. (a -> b -> c) -> Observable a -> Observable b -> Observable c

range :: Int -> Int -> Observable Int

reduce :: forall b a. (a -> b -> b) -> b -> Observable a -> Observable b

delay :: forall a. Int -> Observable a -> Observable a

materialize :: forall a. Observable a -> Observable (Notification a)

dematerialize :: forall a. Observable (Notification a) -> Observable a

distinct :: forall a. Observable a -> Observable a

distinctUntilChanged :: forall a. Observable a -> Observable a

filter :: forall a. (a -> Boolean) -> Observable a -> Observable a

withLatestFrom :: forall c b a. (a -> b -> c) -> Observable a -> Observable b -> Observable c