He-Pin commented on code in PR #1701:
URL: https://github.com/apache/pekko/pull/1701#discussion_r1910319857
##########
stream-tests/src/test/scala/org/apache/pekko/stream/impl/TraversalBuilderSpec.scala:
##########
@@ -447,4 +452,93 @@ class TraversalBuilderSpec extends PekkoSpec {
}
}
+ "find Source.single via TraversalBuilder" in {
+ TraversalBuilder.getSingleSource(Source.single("a")).get.elem should
===("a")
+ TraversalBuilder.getSingleSource(Source(List("a", "b"))) should
be(OptionVal.None)
+
+ val singleSourceA = new SingleSource("a")
+ TraversalBuilder.getSingleSource(singleSourceA) should
be(OptionVal.Some(singleSourceA))
+
+ TraversalBuilder.getSingleSource(Source.single("c").async) should
be(OptionVal.None)
+ TraversalBuilder.getSingleSource(Source.single("d").mapMaterializedValue(_
=> "Mat")) should be(OptionVal.None)
+ }
+
+ "find Source.single via TraversalBuilder with getValuePresentedSource" in {
+
TraversalBuilder.getValuePresentedSource(Source.single("a")).get.asInstanceOf[SingleSource[String]].elem
should ===(
+ "a")
+ val singleSourceA = new SingleSource("a")
+ TraversalBuilder.getValuePresentedSource(singleSourceA) should
be(OptionVal.Some(singleSourceA))
+
+ TraversalBuilder.getValuePresentedSource(Source.single("c").async) should
be(OptionVal.None)
+
TraversalBuilder.getValuePresentedSource(Source.single("d").mapMaterializedValue(_
=> "Mat")) should be(
+ OptionVal.None)
+ }
+
+ "find Source.empty via TraversalBuilder with getValuePresentedSource" in {
+ val emptySource = EmptySource
Review Comment:
@pjfanning the tests coverage is here for the `EmptySource`
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
