File tree Expand file tree Collapse file tree
stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -22,6 +22,7 @@ import java.util.stream.BaseStream
2222import java .util .stream .Collector
2323import java .util .stream .Collector .Characteristics
2424import java .util .stream .Collectors
25+ import java .util .{ Spliterator , Spliterators }
2526
2627import scala .concurrent .Await
2728import scala .concurrent .duration ._
@@ -111,7 +112,7 @@ class StreamConvertersSpec extends StreamSpec with DefaultTimeout {
111112 override def parallel (): EmptyStream = this
112113 override def isParallel : Boolean = false
113114
114- override def spliterator (): util.Spliterator [Unit ] = ???
115+ override def spliterator (): util.Spliterator [Unit ] = Spliterators .emptySpliterator()
115116 override def onClose (closeHandler : Runnable ): EmptyStream = ???
116117
117118 override def iterator (): util.Iterator [Unit ] = new util.Iterator [Unit ] {
@@ -136,7 +137,10 @@ class StreamConvertersSpec extends StreamSpec with DefaultTimeout {
136137 override def parallel (): FailingStream = this
137138 override def isParallel : Boolean = false
138139
139- override def spliterator (): util.Spliterator [Unit ] = ???
140+ override def spliterator (): util.Spliterator [Unit ] = Spliterators .spliteratorUnknownSize(
141+ iterator(),
142+ Spliterator .NONNULL
143+ )
140144 override def onClose (closeHandler : Runnable ): FailingStream = ???
141145
142146 override def iterator (): util.Iterator [Unit ] = new util.Iterator [Unit ] {
You can’t perform that action at this time.
0 commit comments