akka/akka-core

Convenience for attributes on Sink

Open

#30.199 geöffnet am 22. Apr. 2021

Auf GitHub ansehen
 (5 Kommentare) (0 Reaktionen) (0 zugewiesene Personen)Scala (3.547 Forks)batch import
1 - triagedhelp wantedt:stream

Repository-Metriken

Stars
 (13.277 Stars)
PR-Merge-Metriken
 (Durchschn. Merge 17h 35m) (11 gemergte PRs in 30 T)

Beschreibung

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

Contributor Guide

Research-Richtung
Das Issue fordert die Hinzufügung einer Convenience Methode zum direkten Anwenden von Attributen auf `Sink`, ähnlich wie `Flow` bereits `withAttributes` unterstützt. Die Hauptarbeit besteht darin, eine Methode zu `Sink` in der Scala und Java DSL hinzuzufügen (z.B. `akka stream/src/main/scala/akka/stream/scaladsl/Sink.scala` und das Java Gegenstück). Der verlinkte PR #888 liefert den Kontext für den Anwendungsfall. Überprüfen Sie die bestehende Attributbehandlung in `Flow` und stellen Sie sicher, dass die neue Methode eine `Sink` mit den angegebenen Attributen zurückgibt, ohne eine asynchrone Grenze einzuführen.
Tech Stack
Keine
Domain
backend
Issue Type
Funktion
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
3
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
Halber Tag
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
Aktiv
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
Klar
Voraussetzungen
ScalaAkka Streams
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
50