CrossClj

1.1.0 docs

SourceDocs



RECENT
    VARS
    accept
    batch*
    consume
    create
    custom-stream
    dispatcher-types
    filter*
    flush
    fmap*
    fold*
    map*
    mappend*
    maybe-compose
    reduce*
    tap

    « Index of all namespaces of this project

    (accept deferred value)
    (batch* i deferred-or-stream)
    Defines a batch function that will accumulate values until it's reaches count of i, and
    streams the resulting array of values further down.
    (consume stream f)
    Defines a consumer for stream.
    
    (create & {:keys [dispatcher-type dispatcher values batch-size env]})
    Creates a stream processing channel
    
    (custom-stream f deferred-or-stream)
    (filter* f deferred-or-stream)
    Defines a filter function, that will apply predicate f to all events going through it
    and will stream only those for which predicate returned truthy value.
    (flush deferred-or-stream)
    (fmap* f deferred-or-stream)
    (fold* f deferred-or-stream)
    (map* f deferred-or-stream)
    Defines a map function, that will apply f to all events going through it.
    
    (mappend* monoid deferred-or-stream)(mappend* monoid condition deferred-or-stream)
    Private
    (maybe-compose deferred-or-stream)
    (reduce* f default-value deferred-or-stream)(reduce* f deferred-or-stream)
    Defines an aggregator funciton that will apply previous aggregator value and new incoming event
    to function f, receives default-value with which aggregator is initialized.
    (tap stream)