beicon.core
behavior-subject
(behavior-subject v)
Bus that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.
buffer
(buffer n ob)
(buffer n skip ob)
Projects each element of an observable sequence into zero or more buffers which are produced based on element count information.
buffer-time
(buffer-time ms ob)
(buffer-time ms start ob)
(buffer-time ms start max ob)
Buffers the source Observable values for a specific time period.
buffer-until
(buffer-until notifier ob)
Buffers the source Observable values until notifier emits.
catch
(catch handler ob)
(catch pred handler ob)
Continues an observable sequence that is terminated by an exception with the next observable sequence.
combine-latest
(combine-latest obs)
(combine-latest o1 o2)
(combine-latest o1 o2 o3)
(combine-latest o1 o2 o3 o4)
(combine-latest o1 o2 o3 o4 & other)
Combines multiple Observables to create an Observable whose values are calculated from the latest values of each of its input Observables (constructor).
combine-latest-with
(combine-latest-with other ob)
Combines multiple Observables to create an Observable whose values are calculated from the latest values of each of its input Observables (operator).
concat
(concat & more)
Concatenates all of the specified observable sequences, as long as the previous observable sequence terminated successfully.
create
(create sf)
Creates an observable sequence from a specified subscribe method implementation.
debounce
(debounce ms ob)
Emits an item from the source Observable after a particular timespan has passed without the Observable omitting any other items.
dedupe
(dedupe ob)
(dedupe f ob)
Returns an observable sequence that contains only distinct contiguous elements.
dedupe'
(dedupe' ob)
(dedupe' f ob)
Returns an observable sequence that contains only d istinct elements.
Usage of this operator should be considered carefully due to the maintenance of an internal lookup structure which can grow large.
delay
(delay ms ob)
Time shifts the observable sequence by dueTime. The relative time intervals between the values are preserved.
delay-when
(delay-when sf ob)
(delay-when sd sf ob)
Time shifts the observable sequence based on a subscription delay and a delay selector function for each element.
disposable?
(disposable? v)
Check if the provided object is disposable (jvm) or subscription (js).
finalize
(finalize f ob)
Returns an Observable that mirrors the source Observable, but will call a specified function when the source terminates on complete or error.
first
(first ob)
(first f ob)
(first f default ob)
Return an observable that only has the first value of the provided observable. You can optionally pass a predicate and default value.
fjoin
(fjoin & items)
Runs all observable sequences in parallel and collect their last elements.
from
(from v)
Creates an observable from js arrays, clojurescript collections, and promise instance.
from-atom
(from-atom atm)
(from-atom atm {:keys [emit-current-value?], :or {emit-current-value? false}})
from-event
(from-event et ev)
Creates an Observable by attaching an event listener to an event target
if-empty
(if-empty default ob)
Emits a given value if the source Observable completes without emitting any next value, otherwise mirrors the source Observable.
ignore
(ignore ob)
Ignores all elements in an observable sequence leaving only the termination messages.
interval
(interval ms)
Returns an observable sequence that produces a value after each period.
ISubscriber
protocol
Backpressure aware subscriber abstraction.
members
-on-end
(-on-end _)
Subscription termination notification hook.
-on-error
(-on-error _ error)
Subscription error notification hook.
-on-init
(-on-init _ s)
Subscription initialization hook.
-on-next
(-on-next _ s value)
Subscription data notification hook.
last
(last ob)
(last f ob)
(last f default ob)
Return an observable that only has the last value of the provided observable. You can optionally pass a predicate and default value.
mapcat
(mapcat f ob)
Projects each element of an observable sequence to an observable sequence and concatenates the resulting observable sequences or Promises or array/iterable into one observable sequence.
merge
(merge & more)
Merges all the observable sequences and Promises into a single observable sequence.
merge-all
(merge-all ob)
(merge-all concurrency ob)
Merges an observable sequence of observable sequences into an observable sequence.
merge-map
(merge-map f ob)
Projects each element of an observable sequence to an observable sequence and merges the resulting observable sequences or Promises or array/iterable into one observable sequence.
In other languages is called: flatMap or mergeMap.
merge-scan
(merge-scan f seed ob)
Applies an accumulator function over the source Observable where the accumulator function itself returns an Observable, then each intermediate Observable returned is merged into the output Observable.
of
(of a)
(of a b)
(of a b c)
(of a b c d)
(of a b c d e)
(of a b c d e f)
(of a b c d e f & more)
Converts arguments to an observable sequence.
on-end
(on-end ob f)
Subscribes a function to invoke upon graceful termination of the observable sequence.
on-error
(on-error ob f)
Subscribes a function to invoke upon exceptional termination of the observable sequence.
on-value
(on-value ob f)
Subscribes a function to invoke for each element in the observable sequence.
pipe
(pipe ob f)
(pipe ob f1 f2)
(pipe ob f1 f2 f3)
(pipe ob f1 f2 f3 f4)
(pipe ob f1 f2 f3 f4 & rest)
pr-log
(pr-log ob)
(pr-log prefix ob)
Print all values passed through the given observable sequence using pr-str.
race
(race a b)
(race a b & more)
Create an observable that surfaces any of the given sequences, whichever reacted first.
range
(range b)
(range a b)
Generates an observable sequence that repeats the given element.
reduce
(reduce f ob)
(reduce f seed ob)
Applies an accumulator function over an observable sequence, returning the result of the aggregation as a single element in the result sequence.
retry
(retry ob)
(retry n ob)
Given an optional number of retries and an observable, repeats the source observable the specified number of times or until it terminates. If no number of retries is given, it will be retried indefinitely.
scan
(scan f ob)
(scan f seed ob)
Applies an accumulator function over an observable sequence and returns each intermediate result. Same as reduce but with intermediate results
scheduler
(scheduler type)
Get the scheduler instance by type. The posible types are: :asap
, :async
, :queue
. Old :trampoline
type is renamed as :queue
and is deprecated.
skip
(skip n ob)
Bypasses a specified number of elements in an observable sequence and then returns the remaining elements.
skip-until
(skip-until pob ob)
Returns the values from the source observable sequence only after the other observable sequence produces a value.
skip-while
(skip-while f ob)
Bypasses elements in an observable sequence as long as a specified condition is true and then returns the remaining elements.
subject
(subject)
Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.
subs
(subs nf ob)
(subs nf ef ob)
(subs nf ef cf ob)
A specialized version of subscribe
with inverted arguments.
subscribe
(subscribe ob nf)
(subscribe ob nf ef)
(subscribe ob nf ef cf)
Subscribes an observer to the observable sequence.
subscribe-with
(subscribe-with ob observer)
Subscribes an observer or subscriber to the observable sequence.
take
(take n ob)
Bypasses a specified number of elements in an observable sequence and then returns the remaining elements.
take-until
(take-until other ob)
Returns the values from the source observable sequence until the other observable sequence or Promise produces a value.
take-while
(take-while f ob)
Returns elements from an observable sequence as long as a specified predicate returns true.
tap
(tap f ob)
(tap f g ob)
(tap f g e ob)
Invokes an action for each element in the observable sequence.
throttle
(throttle ms ob)
(throttle ms config ob)
Returns an observable sequence that emits only the first item emitted by the source Observable during sequential time windows of a specified duration.
timeout
(timeout ms ob)
(timeout ms other ob)
Returns the source observable sequence or the other observable sequence if dueTime elapses.
timer
(timer delay)
(timer delay period)
Returns an observable sequence that produces a value after ms
has elapsed and then after each period.
to-atom
(to-atom ob)
(to-atom ob a)
(to-atom ob a f)
Materialize the observable sequence into an atom.
with-latest
deprecated
(with-latest f other source)
Merges the specified observable sequences into one observable sequence by using the selector function only when the source observable sequence (the instance) produces an element.
with-latest-from
(with-latest-from other source)
(with-latest-from o1 o2 source)
(with-latest-from o1 o2 o3 source)
(with-latest-from o1 o2 o3 o4 source)
(with-latest-from o1 o2 o3 o4 o5 source)
(with-latest-from o1 o2 o3 o4 o5 o6 source)
Merges the specified observable sequences into one observable sequence by using the selector function only when the source observable sequence (the instance) produces an element.
zip
(zip & items)
Merges the specified observable sequences or Promises (cljs) into one observable sequence.