CrossClj

0.9.0 docs

SourceDocs



RECENT
    VARS
    and
    assign
    awaiting
    buffer-with-count
    buffer-with-time
    buffer-with-time-or-count
    bus
    bus-error
    changes
    combine
    combine-as-array
    combine-template
    combine-with
    constant
    debounce
    debounce-immediate
    delay
    diff
    dispose
    do-action
    end
    end-bus
    end-on-error
    error
    errors
    event-stream
    filter
    flat-map
    flat-map-first
    flat-map-latest
    fold
    from-array
    from-callback
    from-event-target
    from-node-callback
    from-poll
    from-promise
    initial
    interval
    kw->fn
    later
    log
    log-action
    log-pr
    log-with
    make-join-args
    map
    map-apply
    map-end
    map-error
    merge
    merge-all
    never
    next
    no-more
    not
    on-end
    on-error
    on-if
    on-value
    on-values
    once
    or
    plug
    push
    repeatedly
    sample
    sampled-by
    scan
    sequentially
    skip
    skip-duplicates
    skip-until
    skip-while
    sliding-window
    start-with
    subscribe
    take
    take-until
    take-while
    throttle
    to-property
    update
    when
    zip
    zip-as-array
    zip-with

    « Index of all namespaces of this project

    (and prop prop2)
    (assign prop target f & args)
    SUBJECT TOO CHANGE.
    Different than baconjs version.
    Extra args will be applied after the property's value, i.e. (apply f v args)
    (awaiting stream-or-property stream2-or-property2)
    (buffer-with-count stream n)
    (buffer-with-time stream ms-or-defer-fn)
    (buffer-with-time-or-count stream delay count)
    (bus-error bus e)
    (changes prop)
    (combine ???)(combine ???)(combine ???)
    (combine-as-array & streams)
    (combine-template template)
    (combine-with & streams-with-fn)
    (debounce observable ms)
    (debounce-immediate observable ms)
    (delay observable ms)
    (diff observable start f)
    (do-action observable f)
    (end-bus bus)
    (end-on-error ???)(end-on-error ???)
    (errors observable)
    (event-stream f)
    (filter ???)(filter ???)
    (flat-map observable f)
    (flat-map-first observable f)
    (flat-map-latest observable f)
    (fold observable seed f)
    (from-array values)
    (from-callback f)
    (from-event-target target event-name)
    (from-node-callback f)
    (from-poll interval f)
    (from-promise promise)
    (initial value)
    (interval ms value)
    Private
    (kw->fn maybe-kw)
    (later delay value)
    (log stream)
    (log-action sexp)
    (log-pr stream)
    (log-with prefix)
    Private
    (make-join-args observables+fn-pairs)
    (map observable f-or-property)
    (map-apply obs f)
    (map-end observable f-or-property)
    (map-error observable f)
    (merge stream stream2)
    (merge-all streams)
    (next value)
    (not observable)
    (on-end observable f)
    (on-error observable f)
    (on-if obs on-true on-false)
    (on-value observable f)
    (on-values & args)
    (or prop prop2)
    (plug bus stream)
    (push bus x)
    (repeatedly ms values)
    (sample prop ms)
    (sampled-by ???)(sampled-by ???)(sampled-by ???)
    (scan observable seed f)
    (sequentially ms values)
    (skip observable n)
    (skip-duplicates observable & [is-equal])
    (skip-until stream starter)
    (skip-while stream predicate)
    (sliding-window ???)(sliding-window ???)
    (start-with prop value)
    (subscribe observable f)
    (take observable n)
    (take-until observable other)
    (take-while observable f)
    (throttle observable ms)
    (to-property ???)(to-property ???)
    (update init & observables+fn-pairs)
    (when & observables+fn-pairs)
    (zip stream stream2 f)
    (zip-as-array & streams)
    (zip-with & streams-with-fn)