Module

Rx.Observable

Package
purescript-rx
Repository
anttih/purescript-rx

#fromArray Source

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

#generate Source

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

#subscribe' Source

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

#subscribe Source

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

#subscribeOnCompleted Source

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

#subscribeOnError Source

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

#merge Source

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

#combineLatest Source

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

#concat Source

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

#take Source

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

#takeUntil Source

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

#flatMap Source

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

#flatMapLatest Source

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

#scan Source

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

#startWith Source

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

#unwrap Source

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

#runObservable Source

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

#switchLatest Source

#debounce Source

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

#zip Source

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

#reduce Source

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

#delay Source

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

#materialize Source

#dematerialize Source

#distinct Source

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

#distinctUntilChanged Source

#filter Source

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

#withLatestFrom Source

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