diff options
Diffstat (limited to 'src/library/scala/collection/parallel/ParIterableLike.scala')
| -rw-r--r-- | src/library/scala/collection/parallel/ParIterableLike.scala | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/library/scala/collection/parallel/ParIterableLike.scala b/src/library/scala/collection/parallel/ParIterableLike.scala index 4d95043c3a..881ab80038 100644 --- a/src/library/scala/collection/parallel/ParIterableLike.scala +++ b/src/library/scala/collection/parallel/ParIterableLike.scala @@ -141,7 +141,7 @@ self => me: SignalContextPassingIterator[ParIterator] => var signalDelegate: Signalling = IdleSignalling def repr = self.repr - def split: Seq[ParIterator] + def split: Seq[ParIterableIterator[T]] } /** A stackable modification that ensures signal contexts get passed along the iterators. @@ -489,7 +489,9 @@ self => override def take(n: Int): Repr = { val actualn = if (size > n) n else size if (actualn < MIN_FOR_COPY) take_sequential(actualn) - else executeAndWaitResult(new Take(actualn, cbfactory, parallelIterator) mapResult { _.result }) + else executeAndWaitResult(new Take(actualn, cbfactory, parallelIterator) mapResult { + _.result + }) } private def take_sequential(n: Int) = { |