A suckless reactive stream toolkit.
Constructors
new
Creates and returns a stream.
Instance methods
all(from a :
Stream(
M), until b :
Stream(
K), now = false) forall
M,
K Starts to emit when a emits, and stops to emit when b
emits. now can be passed to skip waiting for a to emit
the first time.
batch(count : Int32)
Emits objects from this stream in batches of count elements.
each(func : T -> )
Calls func before emitting an object unchanged.
each
Calls func before emitting an object unchanged.
emit(object : T)
Emits object to all streams that are subscribed to this stream.
forget(stream)
Unsubscribes stream from events in this stream.
Unordrered concatenation: emits objects from both streams.
map
Emits an object transformed by func.
notifies(stream)
Subscribes stream to this stream.
reject
Emits only those objects for which func returns false.
reject(pattern)
Emits only those objects that do not match against
pattern (using ===).
select
Emits only those objects for which func returns true.
select(type : U.class) forall U
Emits only those objects that are of the given type.
select(pattern)
Emits only those objects that match against pattern
(using ===).
uniq
Emits only if the result of func is not equal (==)
to the last emitted value.
The first object is always emitted.
uniq
Emits only if the emitted object is not equal to the
previous emitted object.