Beicon
Reactive Streams for Clojure(Script)
beicon.core
Public variables and functions:
- behavior-subject
- BehaviorSubject
- buffer
- buffer-time
- cancel!
- catch
- combine-latest
- concat
- connect!
- create
- debounce
- dedupe
- dedupe'
- delay
- delay-when
- Disposable
- disposable-atom
- disposable?
- do
- empty
- end
- end!
- error!
- filter
- fjoin
- flat-map
- fork-join
- from-atom
- from-coll
- from-event
- from-promise
- ICancellable
- ignore
- interval
- IObservableValue
- ISubscriber
- ISubscription
- just
- log
- map
- mapcat
- merge
- merge-all
- merge-map
- never
- noop
- Observable
- observable?
- observe-on
- Observer
- observer?
- of
- on-complete
- on-end
- on-error
- on-next
- on-value
- once
- pr-log
- publish
- push!
- race
- range
- reduce
- request!
- retry
- sample
- sample-when
- scan
- scheduler
- Scheduler
- scheduler?
- share
- skip
- skip-until
- skip-while
- subject
- Subject
- subject?
- subscribe
- subscribe-on
- subscribe-with
- Subscriber
- take
- take-until
- take-while
- tap
- throttle
- throw
- timeout
- timer
- to-atom
- transform
- unwrap-composite-exception
- with-latest
- wrap-disposable
- zip