raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

chore: Test if materializerPromise is already completed first. (#2117)

Browse source
This commit is contained in:
He-Pin(kerr) 2025-08-31 18:48:47 +08:00 • committed by GitHub
parent 95820eda15
commit 39cbb3936e
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
stream/src/main/scala/org/apache/pekko/stream/SystemMaterializer.scala
View file

@ -96,7 +96,11 @@ final class SystemMaterializer(system: ExtendedActorSystem) extends Extension {
val materializer: Materializer = {
// block on async creation to make it effectively final
Await.result(systemMaterializerPromise.future, materializerTimeout.duration)
val future = systemMaterializerPromise.future
future.value match {
case Some(value) => value.get
case _ => Await.result(future, materializerTimeout.duration)
}
}
}