View source

class Observable<A>

package interlude.reactive

@:nullSafety(Strict)@:publicFields

Represents a value that can change over time. This is sometimes also called a Stream of values. Has the same resolution requirements as interlude.reactive.Task

Static methods

staticalways<A, B>(o:Observable<A>, value:B):Observable<B>

staticap<A, B>(o:Observable<A ‑> B>, as:Observable<A>):Observable<B>

staticinlineasObservable<X>(value:X):Observable<X>

staticfilter<A>(o:Observable<A>, predicate:A ‑> Bool):Observable<A>

staticfilterFMap<A, B>(o:Observable<A>, predicate:A ‑> Bool, fn:A ‑> Task<B>):Observable<B>

staticfilterMap<A, B>(o:Observable<A>, predicate:A ‑> Bool, fn:A ‑> B):Observable<B>

staticflatMap<A, B>(o:Observable<A>, fn:A ‑> Observable<B>):Observable<B>

staticflatten<A>(oo:Observable<Observable<A>>):Observable<A>

staticmap<A, B>(o:Observable<A>, fn:A ‑> B):Observable<B>

staticreplay<A>(o:Observable<A>):Void

staticunit<A>(o:Observable<A>):Observable<Unit>

staticzip<A, B>(sA:Observable<A>, sB:Observable<B>):Observable<Pair<A, B>>

staticzipWith<A, B, C>(sA:Observable<A>, sB:Observable<B>, fn:(A, B) ‑> C):Observable<C>

Constructor

new(?initial:A)

Variables

@:value(None)read onlylastDispatched:Option<A> = None

@:value([])read onlysubscribers:Array<A ‑> Void> = []

Methods

@:value({ last : true })mutate(fn:A ‑> Void, last:Bool = true):Observable<A>

resolve(value:A):A