beicon.core — funcool/beicon 2020.03.23-1

behavior-subject cljs

(behavior-subject v)

Bus that emits the most recent item it has observed and all subsequent observed items to each subscribed Observer.

BehaviorSubject cljs

buffer cljs

(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 cljs

(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 cljs

(buffer-until notifier ob)

Buffers the source Observable values until notifier emits.

cancel! cljs

catch cljs

(catch handler ob)

(catch pred handler ob)

Continues an observable sequence that is terminated by an exception with the next observable sequence.

combine-latest cljs

(combine-latest other ob)

(combine-latest f other ob)

Combines multiple Observables to create an Observable whose values are calculated from the latest values of each of its input Observables.

concat cljs

(concat & more)

Concatenates all of the specified observable sequences, as long as the previous observable sequence terminated successfully.

concat-all cljs

(concat-all ob)

connect! cljs

(connect! ob)

Connect the connectable observable.

create cljs

(create sf)

Creates an observable sequence from a specified subscribe method implementation.

debounce cljs

(debounce ms ob)

Emits an item from the source Observable after a particular timespan has passed without the Observable omitting any other items.

dedupe cljs

(dedupe ob)

(dedupe f ob)

Returns an observable sequence that contains only distinct contiguous elements.

dedupe' cljs

(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 cljs

(delay ms ob)

Time shifts the observable sequence by dueTime. The relative time intervals between the values are preserved.

delay-when cljs

(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 cljs

disposable? cljs

(disposable? v)

Check if the provided object is disposable (jvm) or subscription (js).

dispose! cljs

(dispose! v)

Dispose resources acquired by the subscription.

do cljs

empty cljs

(empty)

Returns an observable sequence that is already in end state.

end cljs

Mark a value as a final value of the stream.

end! cljs

(end! b)

Ends the given bus stream.

error cljs

error! cljs

(error! b e)

Pushes the given error to the bus stream.

filter cljs

(filter f ob)

Filters the elements of an observable sequence based on a predicate.

finalize cljs

(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 cljs

(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 cljs

(fjoin & items)

Runs all observable sequences in parallel and collect their last elements.

flat-map cljs

fmap cljs

fork-join cljs

from cljs

(from v)

Creates an observable from js arrays, clojurescript collections, and promise instance.

from-atom cljs

(from-atom atm)

from-event cljs

(from-event et ev)

Creates an Observable by attaching an event listener to an event target

IDisposable cljs protocol

-dispose cljs

(-dispose _)

dispose resources.

ignore cljs

(ignore ob)

Ignores all elements in an observable sequence leaving only the termination messages.

interval cljs

(interval ms)

Returns an observable sequence that produces a value after each period.

IObservableValue cljs protocol

-next? cljs

(-next? _)

Returns true if is end value.

-error? cljs

(-error? _)

Returns true if is end value.

-end? cljs

(-end? _)

Returns true if is end value.

ISubscriber cljs protocol

Backpressure aware subscriber abstraction.

-on-end cljs

(-on-end _)

Subscription termination notification hook.

-on-error cljs

(-on-error _ error)

Subscription error notification hook.

-on-init cljs

(-on-init _ s)

Subscription initialization hook.

-on-next cljs

(-on-next _ s value)

Subscription data notification hook.

last cljs

(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.

log cljs

(log ob)

(log prefix ob)

Print all values passed through the given observable sequence.

map cljs

(map f ob)

Apply a function to each element of an observable sequence.

map-indexed cljs

(map-indexed f ob)

mapcat cljs

(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.

mapcat-indexed cljs

(mapcat-indexed f ob)

merge cljs

(merge & more)

Merges all the observable sequences and Promises into a single observable sequence.

merge-all cljs

(merge-all ob)

(merge-all concurrency ob)

Merges an observable sequence of observable sequences into an observable sequence.

merge-map cljs

(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.

Observable cljs

observable? cljs

(observable? ob)

Return true if ob is a instance of Rx.Observable.

observe-on cljs

(observe-on schd ob)

Observer cljs

of cljs

(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-complete cljs

A semantic alias for on-end.

on-end cljs

(on-end ob f)

Subscribes a function to invoke upon graceful termination of the observable sequence.

on-error cljs

(on-error ob f)

Subscribes a function to invoke upon exceptional termination of the observable sequence.

on-next cljs

A semantic alias for on-value.

on-value cljs

(on-value ob f)

Subscribes a function to invoke for each element in the observable sequence.

pipe cljs

(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 cljs

(pr-log ob)

(pr-log prefix ob)

Print all values passed through the given observable sequence using pr-str.

publish cljs

(publish ob)

Create a connectable (hot) observable from other observable.

push! cljs

(push! b v)

Pushes the given value to the bus stream.

race cljs

(race a b)

(race a b & more)

Create an observable that surfaces any of the given sequences, whichever reacted first.

range cljs

(range b)

(range a b)

Generates an observable sequence that repeats the given element.

reduce cljs

(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 cljs

(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.

rx cljs

rxop cljs

sample cljs

(sample ms ob)

Samples the observable sequence at each interval.

sample-when cljs

(sample-when other ob)

Samples the observable sequence at each interval.

scan cljs

(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 cljs

scheduler cljs

(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.

scheduler? cljs

(scheduler? v)

Check if the provided value is Scheduler instance.

share cljs

(share ob)

Returns an observable sequence that shares a single subscription to the underlying sequence.

skip cljs

(skip n ob)

Bypasses a specified number of elements in an observable sequence and then returns the remaining elements.

skip-until cljs

(skip-until pob ob)

Returns the values from the source observable sequence only after the other observable sequence produces a value.

skip-while cljs

(skip-while f ob)

Bypasses elements in an observable sequence as long as a specified condition is true and then returns the remaining elements.

sub! cljs

Subject cljs

subject cljs

(subject)

Subject that, once an Observer has subscribed, emits all subsequently observed items to the subscriber.

subject? cljs

(subject? b)

Check if the provided value is Subject instance.

subscribe cljs

(subscribe ob nf)

(subscribe ob nf ef)

(subscribe ob nf ef cf)

Subscribes an observer to the observable sequence.

subscribe-on cljs

(subscribe-on schd ob)

subscribe-with cljs

(subscribe-with ob observer)

Subscribes an observer or subscriber to the observable sequence.

Subscriber cljs

take cljs

(take n ob)

Bypasses a specified number of elements in an observable sequence and then returns the remaining elements.

take-until cljs

(take-until other ob)

Returns the values from the source observable sequence until the other observable sequence or Promise produces a value.

take-while cljs

(take-while f ob)

Returns elements from an observable sequence as long as a specified predicate returns true.

tap cljs

(tap f ob)

(tap f g ob)

(tap f g e ob)

Invokes an action for each element in the observable sequence.

throttle cljs

(throttle ms ob)

Returns an observable sequence that emits only the first item emitted by the source Observable during sequential time windows of a specified duration.

throw cljs

(throw e)

timeout cljs

(timeout ms ob)

(timeout ms other ob)

Returns the source observable sequence or the other observable sequence if dueTime elapses.

timer cljs

(timer delay)

(timer delay period)

Returns an observable sequence that produces a value after ms has elapsed and then after each period.

to-atom cljs

(to-atom ob)

(to-atom ob a)

(to-atom ob a f)

Materialize the observable sequence into an atom.

to-observable cljs

(to-observable ob)

Coerce a object to an observable instance.

transform cljs

(transform xform ob)

Transform the observable sequence using transducers.

unsub! cljs

with-latest cljs

(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.

zip cljs

(zip & items)

Merges the specified observable sequences or Promises (cljs) into one observable sequence.