akka/akka-core

Convenience for attributes on Sink

Open

#30.199 aperta il 22 apr 2021

Vedi su GitHub
 (5 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 17h 35m) (11 PR mergiate in 30 g)

Descrizione

When working on https://github.com/akka/akka-persistence-cassandra/pull/888 I realized that it wasn't obvious how to set a dispatcher all the way to the Sink (and not introduce async boundary).

My first thought, when I didn't realize that the Sink is also involved, was:

.map(stuff)
.withAttributes(ActorAttributes.dispatcher(theDispatcher))
.runWith(Sink.ignore)

but it should be:

.map(stuff)
.toMat(Sink.ignore)(Keep.right)
.withAttributes(ActorAttributes.dispatcher(theDispatcher))
.run()

Guida contributor

Direzione di ricerca
La richiesta propone di aggiungere un metodo di convenienza per applicare attributi direttamente su `Sink`, simile a come `Flow` supporta già `withAttributes`. Il lavoro principale consiste nell'aggiungere un metodo a `Sink` nei DSL Scala e Java (ad esempio, `akka stream/src/main/scala/akka/stream/scaladsl/Sink.scala` e la controparte Java). La PR collegata #888 fornisce il contesto per il caso d'uso. Rivedere la gestione degli attributi esistente in `Flow` e assicurarsi che il nuovo metodo restituisca un `Sink` con gli attributi specificati senza introdurre un confine asincrono.
Tech stack
Nessuno
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.
Mezza giornata
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
ScalaAkka Streams
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
50