We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aef34f0 commit 2c3e540Copy full SHA for 2c3e540
stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala
@@ -593,7 +593,7 @@ object Source {
593
val maybeValue = futureElement.value
594
if (maybeValue eq None) {
595
fromGraph(new FutureSource[T](futureElement))
596
- } else futureElement.value match {
+ } else maybeValue match {
597
case Some(scala.util.Success(null)) => empty[T]
598
case Some(scala.util.Success(elem)) => single(elem)
599
case Some(scala.util.Failure(ex)) => failed[T](ex)
0 commit comments