diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/impl/TraversalBuilderSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/impl/TraversalBuilderSpec.scala index 484ac0ed47..063b9ec335 100644 --- a/stream-tests/src/test/scala/org/apache/pekko/stream/impl/TraversalBuilderSpec.scala +++ b/stream-tests/src/test/scala/org/apache/pekko/stream/impl/TraversalBuilderSpec.scala @@ -17,7 +17,7 @@ import org.apache.pekko import pekko.NotUsed import pekko.stream._ import pekko.stream.impl.TraversalTestUtils._ -import pekko.stream.scaladsl.Keep +import pekko.stream.scaladsl.{ Keep, Source } import pekko.testkit.PekkoSpec class TraversalBuilderSpec extends PekkoSpec { @@ -447,4 +447,20 @@ class TraversalBuilderSpec extends PekkoSpec { } } + "find Source.empty via TraversalBuilder with isEmptySource" in { + val emptySource = EmptySource + TraversalBuilder.isEmptySource(emptySource) should be(true) + } + + "find javadsl Source.empty via TraversalBuilder with isEmptySource" in { + import pekko.stream.javadsl.Source + val emptySource = Source.empty() + TraversalBuilder.isEmptySource(emptySource) should be(true) + } + + "find scaldsl Source.empty via TraversalBuilder with isEmptySource" in { + val emptySource = Source.empty + TraversalBuilder.isEmptySource(emptySource) should be(true) + } + }