ulmus.signal — ulmus 0.2.3

>! clj/s

(>! signal-$ value)

Puts a new value on the signal. Because this function is imperatively mutative, it should be used sparingly outside of signal definitions.

changed-keys clj/s

(changed-keys s-$)

Takes a signal containing consecuative maps. Returns a signal of the selected keys [gained, lost] between each two emissions.

choose clj/s

(choose selection-$ options)

Returns a signal containing the contents of the signal keyed by the value of selection in the options map.

clone clj/s

(clone s-$)

Creates a copy of a signal

close! clj/s

(close! s-$ & opts)

Closes the signal. Values will no longer be propogated to the signal and it can be garbage collected. If the :transitive? keyed argument is provided, this function will also close any source signals for which s-$ is the only target.

closed? clj/s

(closed? s-$)

Returns true if s-$ is a signal and has been closed, false otherwise.

debounce cljs

(debounce ms s-$)

Returns a signal of the last value emitted on s-$ after ms millis have ellapsed since it receieved a value.

delay cljs

(delay ms s-$)

Returns each value emitted on s-$ after a delay of ms millis.

distinct clj/s

(distinct s-$)

Returns a signal that will suppress consecutively = values on it's argument.

filter clj/s

(filter pred s-$)

Returns a signal of values for which the value on s-$ applied to pred returns truthy.

flatten clj/s

(flatten s-$)

Takes a signal of seqs. Returns a signal that emits each element in the seq individually.

make-signal clj/s

(make-signal init proc inputs)

Creates a new signal.

map clj/s

(map proc & signals)

Returns a signal whose value is proc applied to the values on the signals provided.

merge clj/s

(merge & signals)

Takes any number of signals and returns a signal containing the values emitted by any of them.

partition clj/s

(partition n s-$)

Returns a signal of vectors containing every n elements emitted on s-$.

pickmap clj/s

(pickmap proc s-$)

(pickmap proc s-$ metadata)

s-$ is expected to emit a list of signals. Returns a signal of the values yielded by applying proc to the signal list emitted on s-$

pickmerge clj/s

(pickmerge s-$)

(pickmerge proc s-$)

(pickmerge proc s-$ metadata)

Creates a signal of the values yeilded by calling merge on the list of signals returned on s-$ after applying proc.

pickzip clj/s

(pickzip s-$)

(pickzip proc s-$)

(pickzip proc s-$ metadata)

Creates a signal of the values yeilded by calling zip on the list of signals returned on s-$ after applying proc.

reduce clj/s

(reduce proc init s-$)

Returns a signal whose value is the result of applying proc to the previous value of s-$ and it's current value. init is the initial value of the signal.

sample-on clj/s

(sample-on value-$ sample-$)

Returns a signal that emits value-$'s current value when sample emits a value.

sample-when clj/s

(sample-when value-$ sample-$)

Returns a signal that emits new values from value-$ when sample-$ is assigned a truthy value.

Signal cljs

signal clj/s

(signal)

Creates a new signal without a value, the signal can only ever be updated with >!.

signal-of clj/s

(signal-of v)

Creates a new signal containing the value v

signal? clj/s

(signal? x)

Returns true if x is a signal, false otherwise

slice clj/s

(slice n s-$)

Returns a signal of vectors containing the last n elements emitted on s-$.

splice! clj/s

(splice! to-$ from-$)

Emits the values on to-$ to from-$

start-with! clj/s

(start-with! v s-$)

subscribe! clj/s

(subscribe! s-$ update-proc)

(subscribe! s-$ update-proc closed-proc)

Attaches subscriptions to s-$. update-proc will get called with the value when s-$ emits. closed-proc will get called when s-$ is closed. Should be used sparingly as an imperitive escape hatch for signal changes.

subscribe-closed! clj/s

(subscribe-closed! s-$ proc)

Subscribes a listener for the closing of a signal.

throttle clj/s

(throttle s-$ ms)

Returns new values emitted on s-$ no more than every ms millis.

unsubscribe! clj/s

(unsubscribe! s-$ subscription)

Removes a subscription from s-$.

unsubscribe-all! clj/s

(unsubscribe-all! s-$)

Removes all subscriptions from a signal.

zip clj/s

(zip & signals)

Takes any number of signals and returns a signal containing a vector of each signals latest value.