CrossClj

manifold manifold.stream 0.1.8

SourceDocs



RECENT
    VARS
    ->sink
    ->source
    batch
    buffer
    buffered-stream
    close!
    closed?
    concat
    connect
    connect-via
    connect-via-proxy
    consume-async
    description
    downstream
    drain-into
    drained?
    filter
    lazily-partition-by
    map
    mapcat
    on-closed
    on-drained
    onto
    periodically
    periodically-
    put!
    put-all!
    realize-each
    reduce
    reductions
    sink-only
    sink?
    source-only
    source?
    splice
    stream
    stream*
    stream->seq
    stream?
    synchronous?
    take!
    throttle
    transform
    try-put!
    try-take!
    weak-handle