akka/akka-core

Convenience for attributes on Sink

Ouverte

#30 199 ouverte le 22 avr. 2021

Voir sur GitHubGuide contributeur
 (5 commentaires) (0 réaction) (0 personne assignée)Scala (3 547 forks)batch import
1 - triagedhelp wantedt:stream

Métriques du dépôt

Stars
 (13 277 étoiles)
Métriques de merge PR
 (Merge moyen 8j 19h) (10 PRs mergées en 30 j)

Description

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()

Guide contributeur

Direction de recherche
Cette demande propose d'ajouter une méthode de commodité pour appliquer des attributs directement sur `Sink`, similaire à la manière dont `Flow` prend déjà en charge `withAttributes`. Le travail principal consiste à ajouter une méthode à `Sink` dans les DSL Scala et Java (par exemple, `akka stream/src/main/scala/akka/stream/scaladsl/Sink.scala` et sa contrepartie Java). La PR liée #888 fournit le contexte pour le cas d'utilisation. Examinez la gestion existante des attributs dans `Flow` et assurez vous que la nouvelle méthode renvoie un `Sink` avec les attributs spécifiés sans introduire de frontière asynchrone.
Stack technique
Aucun
Domaine
backend
Type d'issue
Fonctionnalité
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
3
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
Une demi journée
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
Active
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
Claire
Prérequis
ScalaAkka Streams
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
50