Skip to content

Commit

Permalink
add partition operator in stream graph docs (#1093)
Browse files Browse the repository at this point in the history
Signed-off-by: Andy.Chen <[email protected]>
  • Loading branch information
Roiocam authored Feb 1, 2024
1 parent 7de1fb2 commit a55ebc3
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions docs/src/main/paradox/stream/stream-graphs.md
Original file line number Diff line number Diff line change
Expand Up @@ -39,6 +39,7 @@ Pekko Streams currently provide these junctions (for a detailed list see the @re

* @scala[`Broadcast[T]`]@java[`Broadcast<T>`]*(1 input, N outputs)* given an input element emits to each output
* @scala[`Balance[T]`]@java[`Balance<T>`]*(1 input, N outputs)* given an input element emits to one of its output ports
* @scala[`Partition[T]]`]@java[`Partition<T>`]*(1 input, N outputs)* given an input element emits to specified output based on a partition function
* @scala[`UnzipWith[In,A,B,...]`]@java[`UnzipWith<In,A,B,...>`]*(1 input, N outputs)* takes a function of 1 input that given a value for each input emits N output elements (where N <= 20)
* @scala[`UnZip[A,B]`]@java[`UnZip<A,B>`]*(1 input, 2 outputs)* splits a stream of @scala[`(A,B)`]@java[`Pair<A,B>`] tuples into two streams, one of type `A` and one of type `B`

Expand Down

0 comments on commit a55ebc3

Please sign in to comment.