Skip to content

Commit def84bf

Browse files
authored
chore: fix failed in StreamConvertersSpec (#1655)
1 parent 7fef5b7 commit def84bf

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/StreamConvertersSpec.scala

+6-2
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ import java.util.stream.BaseStream
2222
import java.util.stream.Collector
2323
import java.util.stream.Collector.Characteristics
2424
import java.util.stream.Collectors
25+
import java.util.{ Spliterator, Spliterators }
2526

2627
import scala.concurrent.Await
2728
import 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] {

0 commit comments

Comments
 (0)