[GitHub] [incubator-pekko] He-Pin commented on a diff in pull request #43: !str Eagerly fails flow if the future is already failed.

[GitBox <gi...@apache.org>]

He-Pin commented on code in PR #43:
URL: https://github.com/apache/incubator-pekko/pull/43#discussion_r1021098482


##########
akka-stream-tests/src/test/scala/akka/stream/scaladsl/FlowFromFutureSpec.scala:
##########
@@ -33,6 +34,13 @@ class FlowFromFutureSpec extends StreamSpec {
       c.expectSubscriptionAndError(ex)
     }
 
+    "fails flow from already failed Future even no demands" in {
+      val ex = new RuntimeException("test") with NoStackTrace
+      val sub = Source.fromFuture(Future.failed[Int](ex))
+        .runWith(TestSink.probe)
+      sub.expectSubscriptionAndError(ex)

Review Comment:
   a new test added



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@pekko.apache.org
For additional commands, e-mail: notifications-help@pekko.apache.org