CrossClj

funcool/beicon beicon.core 4.1.0

SourceDocs



RECENT
    VARS
    -cancel
    -cancel $
    -end?
    -end? ?
    -end? Object
    -end? Reduced
    -end? Throwable
    -error?
    -error? ?
    -error? Object
    -error? Reduced
    -error? Throwable
    -next?
    -next? ?
    -next? Object
    -next? Reduced
    -next? Throwable
    -on-end
    -on-error
    -on-init
    -on-next
    -request
    -request $
    aref->disposable
    aref->subscription
    as-action
    as-backpressure-strategy
    as-bifunction
    as-consumer
    as-function
    as-predicate
    behavior-subject
    buffer
    buffer-time
    cancel!
    catch
    combine-latest
    concat
    connect!
    create
    debounce
    dedupe
    dedupe'
    delay
    delay-when
    disposable-atom
    disposable?
    do
    empty
    end
    end!
    error!
    filter
    flat-map
    flowable?
    from-atom
    from-coll
    from-future
    from-publisher
    generate
    ICancellable
    ignore
    interval
    IObservableValue
    ISubscriber
    ISubscription
    just
    log
    map
    mapcat
    merge
    merge-map
    never
    noop
    noop-consumer
    observable?
    observe-on
    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?
    share
    single?
    skip
    skip-until
    skip-while
    subject
    subject?
    subscribe
    subscribe-flowable-with-isubscriber
    subscribe-observable-with-isubscriber
    subscribe-on
    subscribe-to-flowable
    subscribe-to-observable
    subscribe-with
    subscribe-with-observer
    take
    take-until
    take-while
    tap
    throttle
    throw
    timeout
    timer
    to-atom
    to-flowable
    to-serialized
    transform
    unwrap-composite-exception
    with-latest
    wrap-disposable
    zip