@@ -26,10 +26,10 @@ object CollectionConverters {
26
26
implicit class IterableIsParallelizable [A ](private val coll : sc.Iterable [A ]) extends AnyVal with sc.CustomParallelizable [A , ParIterable [A ]] {
27
27
def seq = coll
28
28
override def par = coll match {
29
- case coll : sc.Set [A ] => new SetIsParallelizable (coll).par
29
+ case coll : sc.Set [A @ unchecked ] => new SetIsParallelizable (coll).par
30
30
case coll : sc.Map [_, _] => new MapIsParallelizable (coll).par.asInstanceOf [ParIterable [A ]]
31
31
case coll : sci.Iterable [A ] => new ImmutableIterableIsParallelizable (coll).par
32
- case coll : scm.Iterable [A ] => new MutableIterableIsParallelizable (coll).par
32
+ case coll : scm.Iterable [A @ unchecked ] => new MutableIterableIsParallelizable (coll).par
33
33
case _ => ParIterable .newCombiner[A ].fromSequential(seq) // builds ParArray, same as for scm.Iterable
34
34
}
35
35
}
@@ -48,15 +48,15 @@ object CollectionConverters {
48
48
def seq = coll
49
49
override def par = coll match {
50
50
case coll : sci.Seq [A ] => new ImmutableSeqIsParallelizable (coll).par
51
- case coll : sci.Set [A ] => new ImmutableSetIsParallelizable (coll).par
51
+ case coll : sci.Set [A @ unchecked ] => new ImmutableSetIsParallelizable (coll).par
52
52
case coll : sci.Map [_, _] => new ImmutableMapIsParallelizable (coll).par.asInstanceOf [immutable.ParIterable [A ]]
53
53
case _ => immutable.ParIterable .newCombiner[A ].fromSequential(seq) // builds ParVector
54
54
}
55
55
}
56
56
57
57
// Seq
58
58
implicit def seqIsParallelizable [A ](coll : sc.Seq [A ]): sc.Parallelizable [A , ParSeq [A ]] = coll match {
59
- case it : scm.Seq [A ] => new MutableSeqIsParallelizable (it)
59
+ case it : scm.Seq [A @ unchecked ] => new MutableSeqIsParallelizable (it)
60
60
case it : sci.Seq [A ] => new ImmutableSeqIsParallelizable (it)
61
61
case _ => throw new IllegalArgumentException (" Unexpected type " + coll.getClass.getName+ " - every scala.collection.Seq must be a scala.collection.mutable.Seq or scala.collection.immutable.Seq" )
62
62
}
@@ -144,7 +144,7 @@ object CollectionConverters {
144
144
def seq = coll
145
145
override def par = coll match {
146
146
case coll : sci.Map [K , V ] => new ImmutableMapIsParallelizable (coll).par
147
- case coll : scm.Map [K , V ] => new MutableMapIsParallelizable (coll).par
147
+ case coll : scm.Map [K @ unchecked , V @ unchecked ] => new MutableMapIsParallelizable (coll).par
148
148
case _ => ParMap .newCombiner[K , V ].fromSequential(seq)
149
149
}
150
150
}
0 commit comments