akka/akka-core

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

Open

#19.144 aperta il 10 dic 2015

Vedi su GitHub
 (0 commenti) (0 reazioni) (0 assegnatari)Scala (3547 fork)batch import
1 - triagedhelp wantedt:stream

Metriche repository

Star
 (13.277 star)
Metriche merge PR
 (Merge medio 8g 19h) (10 PR mergiate in 30 g)

Descrizione

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

Guida contributor

Direzione di ricerca
Studia l'API Akka Streams per comprendere il comportamento attuale di .balance su Flow/Source, il concetto di SubFlow e come utilizzare junction statiche per implementare il parallelismo preservando l'ordine. Cerca discussioni o proposte esistenti nella comunità Akka.
Tech stack
scala
Dominio
backend
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
1-2 giorni
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Datata
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Richiede indagine
Prerequisiti
ScalaAkka
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
20