akka/akka-core

Source.fromPublisher does not pick up attributes correctly

Open

#30 076 ouverte le 3 mars 2021

Voir sur GitHub
 (12 commentaires) (0 réactions) (0 assignés)Scala (3 547 forks)batch import
1 - triagedhelp wantedt:stream

Métriques du dépôt

Stars
 (13 277 stars)
Métriques de merge PR
 (Merge moyen 17h 35m) (11 PRs mergées en 30 j)

Description

Looks like Source.fromPublisher buffers some data from the source. I couldn't find any way to limit or disable the buffer size.

  val source3 = Source.fromPublisher {
    Source.fromIterator(() => Iterator.from(1))
      .takeWhile(_ < 50)
      .map { i =>
        println(s"internal akka: $i")
        i
      }
      .runWith(Sink.asPublisher(false))
  }.map { i =>
    Thread.sleep(2000)
    println(s"akka: $i")
    i
  }

log:

internal akka: 1
internal akka: 2
internal akka: 3
internal akka: 4
internal akka: 5
internal akka: 6
internal akka: 7
internal akka: 8
internal akka: 9
akka: 1
akka: 2
akka: 3
.
.
.
.

Originally I faced with this issue converting from Monix reactive streams to Akka-streams.

Guide contributeur

Direction de recherche
Examinez le comportement de mise en tampon interne de Source.fromPublisher dans Akka Streams, en particulier comment il interagit avec la contre pression et la configuration de la taille du tampon. Regardez le code source et les cas de test pour comprendre la mise en tampon implicite et suggérez des moyens de la rendre configurable ou documentée.
Stack technique
scala
Domaine
backend
Type d'issue
Bug
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.
Plutôt claire
Prérequis
ScalaAkka Streams
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
40