View source

class thx.stream.Value<T> extends Emitter<T>

Available on all platforms

Class Fields

static function createOption<T>(?value:T, ?equals:T -> T -> Bool):Value<Option<T>>

Instance Fields

Toggle inherited fields

function audit(handler:T -> Void):Emitter<T>

defined by Emitter

function clear():Void

function clearEmitters():Void

function clearStreams():Void

function concat(other:Emitter<T>):Emitter<T>

defined by Emitter

function count():Emitter<Int>

defined by Emitter

function debounce(delay:Int):Emitter<T>

defined by Emitter

Available on java, js

function delay(time:Int):Emitter<T>

defined by Emitter

Available on java, js

function diff<TOut>(?init:T, f:T -> T -> TOut):Emitter<TOut>

defined by Emitter

function distinct(?equals:T -> T -> Bool):Emitter<T>

defined by Emitter

function feed(value:Value<T>):IStream

defined by Emitter

function filter(f:T -> Bool):Emitter<T>

defined by Emitter

function filterFuture(f:T -> Future<Bool>):Emitter<T>

defined by Emitter

function filterPromise(f:T -> Promise<Bool>):Emitter<T>

defined by Emitter

function first():Emitter<T>

defined by Emitter

function get():T

function last():Emitter<T>

defined by Emitter

function log(?prefix:String, ?posInfo:PosInfos):Emitter<T>

defined by Emitter

function map<TOut>(f:T -> TOut):Emitter<TOut>

defined by Emitter

function mapFuture<TOut>(f:T -> Future<TOut>):Emitter<TOut>

defined by Emitter

function mapPromise<TOut>(f:T -> Promise<TOut>):Emitter<TOut>

defined by Emitter

function memberOf(arr:Array<T>, ?equality:T -> T -> Bool):Emitter<T>

defined by Emitter

function merge(other:Emitter<T>):Emitter<T>

defined by Emitter

function new(value:T, ?equals:T -> T -> Bool):Void

function notNull():Emitter<T>

defined by Emitter

function pair<TOther>(other:Emitter<TOther>):Emitter<Tuple2<T, TOther>>

defined by Emitter

function plug(bus:Bus<T>):IStream

defined by Emitter

function previous():Emitter<T>

defined by Emitter

function reduce<TOut>(acc:TOut, f:TOut -> T -> TOut):Emitter<TOut>

defined by Emitter

function sampleBy<TOther>(sampler:Emitter<TOther>):Emitter<Tuple2<T, TOther>>

defined by Emitter

function samplerOf<TOther>(sampled:Emitter<TOther>):Emitter<Tuple2<T, TOther>>

defined by Emitter

function set(value:T):Void

function sign(subscriber:StreamValue<T> -> Void):IStream

defined by Emitter

function skip(n:Int):Emitter<T>

defined by Emitter

function skipUntil(predicate:T -> Bool):Emitter<T>

defined by Emitter

function split():Tuple2<Emitter<T>, Emitter<T>>

defined by Emitter

Available on java, js

function subscribe(?pulse:T -> Void, ?end:Bool -> Void):IStream

defined by Emitter

function take(count:Int):Emitter<T>

defined by Emitter

function takeAt(index:Int):Emitter<T>

defined by Emitter

function takeLast(n:Int):Emitter<T>

defined by Emitter

function takeUntil(f:T -> Bool):Emitter<T>

defined by Emitter

function toFalse():Emitter<Bool>

defined by Emitter

function toNil():Emitter<Nil>

defined by Emitter

function toOption():Emitter<Option<T>>

defined by Emitter

function toTrue():Emitter<Bool>

defined by Emitter

function toValue<T>(value:T):Emitter<T>

defined by Emitter

function window(size:Int, emitWithLess:Bool = false):Emitter<Array<T>>

defined by Emitter

function withValue(expected:T):Emitter<T>

defined by Emitter

function zip<TOther>(other:Emitter<TOther>):Emitter<Tuple2<T, TOther>>

defined by Emitter