akka/akka-core

.balance defined n Flow/Source, to return a SubFlow

Open

#19,144 建立於 2015年12月10日

在 GitHub 查看
 (0 留言) (0 反應) (0 負責人)Scala (3,547 fork)batch import
1 - triagedhelp wantedt:stream

倉庫指標

Star
 (13,277 star)
PR 合併指標
 (平均合併 8天 19小時) (30 天內合併 10 個 PR)

描述

ktoso 11:06 what's the plan about Balance being defined on Flow/Source - we don't? // cc @rkuhn @drewhk found myself that it would look nice for demoing "look, it's parallel now"

rkuhn 11:06 .balance should actually give you a SubFlow so that we can materialize that a number of times to exploit parallelism while losing ordering and if it takes a (strict) integer argument for the parallelism then we can actually desugar that into static > junctions

貢獻者指南