akka/akka-core

Convenience for attributes on Sink

Aberta

#30.199 aberto em 22 de abr. de 2021

Ver no GitHubGuia do colaborador
 (5 comentários) (0 reação) (0 responsável)Scala (3.547 forks)batch import
1 - triagedhelp wantedt:stream

Métricas do repositório

Stars
 (13.277 estrelas)
Métricas de merge de PR
 (Mesclagem média 8d 19h) (10 fundiu PRs em 30d)

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

Guia do colaborador

Direção de pesquisa
A issue solicita a adição de um método de conveniência para aplicar atributos diretamente em `Sink`, similar a como `Flow` já suporta `withAttributes`. O trabalho principal envolve adicionar um método a `Sink` no DSL Scala e Java (por exemplo, `akka stream/src/main/scala/akka/stream/scaladsl/Sink.scala` e sua contraparte Java). A PR vinculada #888 fornece contexto para o caso de uso. Revise o tratamento de atributos existente em `Flow` e garanta que o novo método retorne um `Sink` com os atributos especificados sem introduzir uma fronteira assíncrona.
Pilha de tecnologia
None
Domain
backend
Tipo Issue
Funcionalidade
DifficultyDificuldade de implementação estimada para um novo contribuidor, de 1 para alterações muito pequenas a 5 para trabalho de nível especializado.
3
Tempo estimadoUm intervalo de tempo aproximado para um colaborador experiente investigar, implementar, testar e preparar um pull request.
Meio dia
Status da atividadeQuão disponível o issue aparece agora: novo, ativo, obsoleto, bloqueado ou aguardando entrada do mantenedor.
Ativo
ClarityCom que clareza o issue explica a mudança esperada, os critérios de aceitação e a próxima etapa.
Claro
Prerequisites
ScalaAkka Streams
Simpatia para novatosUma pontuação de 1 a 100 que estima o quão acessível este issue é para colaboradores iniciantes.
50