Liking cljdoc? Tell your friends :D

fr33m0nk.akka.stream


create-flowclj

(create-flow)
source

draining-substream-cancel-strategyclj

source

flow-from-functionclj

(flow-from-function f)
source

flow-from-graphclj

(flow-from-graph graph)
source

flow-from-materializerclj

(flow-from-materializer f)
source

flow-from-sink-and-sourceclj

(flow-from-sink-and-source sink source)
source

IStreamOperationscljprotocol

reduceclj

(reduce source-or-flow reducer-fn)

Start with first element and then apply the current and next value to the given function, when upstream complete the current value is emitted downstream. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/reduce.html

Start with first element and then apply the current and next value to the given function, when upstream complete the current value is emitted downstream.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/reduce.html

concat-lazyclj

(concat-lazy source-or-flow stream)

After completion of the original upstream the elements of the given source will be emitted. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/concatLazy.html

After completion of the original upstream the elements of the given source will be emitted.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/concatLazy.html

takeclj

(take source-or-flow n)

Pass n incoming elements downstream and then complete https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/take.html

Pass n incoming elements downstream and then complete
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/take.html

mapclj

(map source-or-flow mapping-fn)

Transform each element in the stream by calling a mapping function with it and passing the returned value downstream https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/map.html

Transform each element in the stream by calling a mapping function with it and passing the returned value downstream
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/map.html

run-withclj

(run-with source-or-flow source sink materializer-or-actor-system)

mapcatclj

(mapcat source-or-flow mapping-fn)

Transform each element into zero or more elements that are individually passed downstream https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mapConcat.html

Transform each element into zero or more elements that are individually passed downstream
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mapConcat.html

toclj

(to source-or-flow sink)

to-matclj

(to-mat source-or-flow sink combiner-fn)

map-asyncclj

(map-async source-or-flow parallelism mapping-fn)
(map-async source-or-flow parallelism mapping-fn then-fn)

Pass incoming elements to a function that return a CompletionStage result https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mapAsync.html

Pass incoming elements to a function that return a CompletionStage result
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mapAsync.html

take-whileclj

(take-while source-or-flow pred?)
(take-while source-or-flow pred? inclusive?)

Pass elements downstream as long as a predicate function returns true and then complete. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/takeWhile.html

Pass elements downstream as long as a predicate function returns true and then complete.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/takeWhile.html

groupedclj

(grouped source-or-flow size)

Accumulate incoming events until the specified number of elements have been accumulated and then pass the collection of elements downstream. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/grouped.html

Accumulate incoming events until the specified number of elements have been accumulated and then pass the collection of elements downstream.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/grouped.html

map-materialized-valueclj

(map-materialized-value source-or-flow bi-mapping-fn)

runclj

(run source-or-flow actor-system)

flatmap-mergeclj

(flatmap-merge source-or-flow breadth mapping-fn)

Transform each input element into a Source whose elements are then flattened into the output stream through merging. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/flatMapMerge.html

Transform each input element into a Source whose elements are then flattened into the output stream through merging.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/flatMapMerge.html

split-whenclj

(split-when source-or-flow pred?)
(split-when source-or-flow substream-cancel-strategy pred?)

Split off elements into a new substream whenever a predicate function return true. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/splitWhen.html

Split off elements into a new substream whenever a predicate function return true.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/splitWhen.html

via-matclj

(via-mat source-or-flow flow combiner-fn)

concat-all-lazyclj

(concat-all-lazy source-or-flow streams)

After completion of the original upstream the elements of the given sources will be emitted sequentially https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/concatAllLazy.html

After completion of the original upstream the elements of the given sources will be emitted sequentially
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/concatAllLazy.html

group-byclj

(group-by source-or-flow max-substreams grouping-fn)
(group-by source-or-flow
          max-substreams
          grouping-fn
          allow-closed-substream-recreation?)

Demultiplex the incoming stream into separate output streams. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupBy.html

Demultiplex the incoming stream into separate output streams.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/groupBy.html

concatclj

(concat source-or-flow stream)

After completion of the original upstream the elements of the given source will be emitted. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/concat.html

After completion of the original upstream the elements of the given source will be emitted.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/concat.html

viaclj

(via source-or-flow flow)

slidingclj

(sliding source-or-flow count step-size)

Provide a sliding window over the incoming stream and pass the windows as groups of elements downstream. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/sliding.html

Provide a sliding window over the incoming stream and pass the windows as groups of elements downstream.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/sliding.html

dropclj

(drop source-or-flow n)

Drop n elements and then pass any subsequent element downstream. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/drop.html

Drop n elements and then pass any subsequent element downstream.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/drop.html

foldclj

(fold source-or-flow zero-value fold-fn)

Start with current value zero and then apply the current and next value to the given function. When upstream completes, the current value is emitted downstream. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/fold.html

Start with current value zero and then apply the current and next value to the given function. When upstream completes, the current value is emitted downstream.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/fold.html

mergeclj

(merge source-or-flow stream)
(merge source-or-flow stream eager-complete?)
Merge multiple sources.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/merge.html

map-async-unorderedclj

(map-async-unordered source-or-flow parallelism mapping-fn)
(map-async-unordered source-or-flow parallelism mapping-fn then-fn)

Like mapAsync but CompletionStage results are passed downstream as they arrive regardless of the order of the elements that triggered them https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mapAsyncUnordered.html

Like mapAsync but CompletionStage results are passed downstream as they arrive regardless of the order of the elements that triggered them
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mapAsyncUnordered.html

merge-allclj

(merge-all source-or-flow streams eager-complete?)
Merge multiple sources.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mergeAll.html

filterclj

(filter source-or-flow pred?)
Filter the incoming elements using a predicate.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/filter.html

split-afterclj

(split-after source-or-flow pred?)
(split-after source-or-flow substream-cancel-strategy pred?)

End the current substream whenever a predicate returns true, starting a new substream for the next element. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/splitAfter.html

End the current substream whenever a predicate returns true, starting a new substream for the next element.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/splitAfter.html

flatmap-concatclj

(flatmap-concat source-or-flow mapping-fn)

Transform each input element into a Source whose elements are then flattened into the output stream through concatenation https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/flatMapConcat.html

Transform each input element into a Source whose elements are then flattened into the output stream through concatenation
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/flatMapConcat.html

fold-asyncclj

(fold-async source-or-flow zero-value fold-fn)
(fold-async source-or-flow zero-value fold-fn then-fn)

Just like fold but receives a function that results in a CompletionStage to the next value. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/foldAsync.html

Just like fold but receives a function that results in a CompletionStage to the next value.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/foldAsync.html

drop-whileclj

(drop-while source-or-flow pred?)

Drop elements as long as a predicate function return true for the element https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/dropWhile.html

Drop elements as long as a predicate function return true for the element
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/dropWhile.html

map-async-partitionedclj

(map-async-partitioned source-or-flow
                       parallelism
                       per-partition-count
                       partitioner-fn
                       bi-mapper-fn)

Pass incoming elements to a function that extracts a partitioning key from the element, then to a function that returns a CompletionStage result, bounding the number of incomplete CompletionStages per partitioning key. https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mapAsyncPartitioned.html

Pass incoming elements to a function that extracts a partitioning key from the element, then to a function that returns a CompletionStage result, bounding the number of incomplete CompletionStages per partitioning key.
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/mapAsyncPartitioned.html

filter-falsyclj

(filter-falsy source-or-flow pred?)
Filter the incoming elements using a predicate
https://doc.akka.io/docs/akka/current/stream/operators/Source-or-Flow/filterNot.html
source

ISubStreamOperationscljprotocol

also-to-allclj

(also-to-all sub-source-or-flow streams)

concat-substreamsclj

(concat-substreams sub-source-or-flow)

merge-substreamsclj

(merge-substreams sub-source-or-flow)

merge-substreams-with-parallelismclj

(merge-substreams-with-parallelism sub-source-or-flow parallelism)
source

propagate-substream-cancel-strategyclj

source

source-from-graphclj

(source-from-graph graph)
source

source-from-materializerclj

(source-from-materializer f)
source

cljdoc is a website building & hosting documentation for Clojure/Script libraries

× close