akka/akka-core

Unstashed messages enqueued in TestActorRef mailbox while processing a message from self are stuck until another message is received

Ouverte

#30 170 ouverte le 7 avr. 2021

Voir sur GitHubGuide contributeur
 (1 commentaire) (0 réaction) (0 personne assignée)Scala (3 547 forks)batch import
help wantednice-to-have (low-prio)t:testing

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

In the following workflow, unstashed messages are enqueued in the mailbox but are not processed as expected:

  1. Send message (messageOne) from TestKit to TestActorRef
  2. TestActorRef underlying actor stashes messageOne and schedules a subsequent message to self (selfMessage)
  3. selfMessage is sent and processed and messageOne is unstashed during processing of selfMessage
  4. messageOne is not processed
  5. Send another message (messageTwo) from TestKit to TestActorRef
  6. Both messageOne and messageTwo are processed

akka.testkit.CallingThreadDispatcher#runQueue appears to process the provided MessageQueue at the time of invocation rather than using the active Mailbox MessageQueue.

Guide contributeur

Direction de recherche
Examinez l'implémentation de CallingThreadDispatcher.runQueue et comment il gère la file d'attente de la boîte aux lettres, en particulier lors des opérations de stash/unstash.
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.
4
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
1-2 jours
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
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
30