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

贡献者指南