From a55ebc3b79eb059c18287512d926d5cb1d00e141 Mon Sep 17 00:00:00 2001 From: "AndyChen(JingZhangChen)" Date: Thu, 1 Feb 2024 23:21:49 +0800 Subject: [PATCH] add partition operator in stream graph docs (#1093) Signed-off-by: Andy.Chen --- docs/src/main/paradox/stream/stream-graphs.md | 1 + 1 file changed, 1 insertion(+) diff --git a/docs/src/main/paradox/stream/stream-graphs.md b/docs/src/main/paradox/stream/stream-graphs.md index 6e1067e635a..23cdabf9071 100644 --- a/docs/src/main/paradox/stream/stream-graphs.md +++ b/docs/src/main/paradox/stream/stream-graphs.md @@ -39,6 +39,7 @@ Pekko Streams currently provide these junctions (for a detailed list see the @re * @scala[`Broadcast[T]`]@java[`Broadcast`] – *(1 input, N outputs)* given an input element emits to each output * @scala[`Balance[T]`]@java[`Balance`] – *(1 input, N outputs)* given an input element emits to one of its output ports + * @scala[`Partition[T]]`]@java[`Partition`] – *(1 input, N outputs)* given an input element emits to specified output based on a partition function * @scala[`UnzipWith[In,A,B,...]`]@java[`UnzipWith`] – *(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`] – *(1 input, 2 outputs)* splits a stream of @scala[`(A,B)`]@java[`Pair`] tuples into two streams, one of type `A` and one of type `B`