.

Author: He-Pin

stream/src/main/scala/org/apache/pekko/stream/scaladsl/Source.scala

@@ -589,16 +589,11 @@ object Source {
    * Emits a single value when the given `Future` is successfully completed and then completes the stream.
    * The stream fails if the `Future` is completed with a failure.
    */
-  def future[T](futureElement: Future[T]): Source[T, NotUsed] = {
-    val maybeValue = futureElement.value
-    if (maybeValue eq None) {
-      fromGraph(new FutureSource[T](futureElement))
-    } else maybeValue match {
-      case Some(scala.util.Success(null)) => empty[T]
-      case Some(scala.util.Success(elem)) => single(elem)
-      case Some(scala.util.Failure(ex))   => failed[T](ex)
-      case _                              => throw new IllegalStateException("unexpected case") // will not happen, for exhaustiveness check
-    }
+  def future[T](futureElement: Future[T]): Source[T, NotUsed] = futureElement.value match {
+    case None                           => fromGraph(new FutureSource[T](futureElement))
+    case Some(scala.util.Success(null)) => empty[T]
+    case Some(scala.util.Success(elem)) => single(elem)
+    case Some(scala.util.Failure(ex))   => failed[T](ex)
   }
 
   /**
@@ -621,18 +616,13 @@ object Source {
    * Turn a `Future[Source]` into a source that will emit the values of the source when the future completes successfully.
    * If the `Future` is completed with a failure the stream is failed.
    */
-  def futureSource[T, M](futureSource: Future[Source[T, M]]): Source[T, Future[M]] = {
-    val maybeValue = futureSource.value
-    if (maybeValue eq None) {
-      fromGraph(new FutureFlattenSource(futureSource))
-    } else maybeValue match {
-      case Some(scala.util.Success(null)) =>
-        val exception = new NullPointerException("futureSource completed with null")
-        Source.failed(exception).mapMaterializedValue(_ => Future.failed[M](exception))
-      case Some(scala.util.Success(source)) => source.mapMaterializedValue(Future.successful)
-      case Some(scala.util.Failure(ex))     => Source.failed[T](ex).mapMaterializedValue(_ => Future.failed[M](ex))
-      case _                                => throw new IllegalStateException("unexpected case") // will not happen, for exhaustiveness check
-    }
+  def futureSource[T, M](futureSource: Future[Source[T, M]]): Source[T, Future[M]] = futureSource.value match {
+    case None                           => fromGraph(new FutureFlattenSource(futureSource))
+    case Some(scala.util.Success(null)) =>
+      val exception = new NullPointerException("futureSource completed with null")
+      Source.failed(exception).mapMaterializedValue(_ => Future.failed[M](exception))
+    case Some(scala.util.Success(source)) => source.mapMaterializedValue(Future.successful)
+    case Some(scala.util.Failure(ex))     => Source.failed[T](ex).mapMaterializedValue(_ => Future.failed[M](ex))
   }
 
   /**