File tree 3 files changed +20
-3
lines changed
core/src/main/scala/scala/collection/parallel
junit/src/test/scala/scala/collection/parallel
3 files changed +20
-3
lines changed Original file line number Diff line number Diff line change @@ -5,9 +5,9 @@ import: scala/scala-dev:travis/default.yml
5
5
language : scala
6
6
7
7
scala :
8
- - 2.13.4
9
8
- 3.0.0-M3
10
9
- 3.0.0-RC1
10
+ - 2.13.4
11
11
12
12
env :
13
13
- ADOPTOPENJDK=8
Original file line number Diff line number Diff line change @@ -550,7 +550,11 @@ extends IterableOnce[T @uncheckedVariance]
550
550
def apply () = shared
551
551
def doesShareCombiners = true
552
552
} else new CombinerFactory [T , Repr ] {
553
- def apply () = newCombiner
553
+ def apply () = {
554
+ val r = newCombiner
555
+ r.combinerTaskSupport = tasksupport
556
+ r
557
+ }
554
558
def doesShareCombiners = false
555
559
}
556
560
}
@@ -563,7 +567,11 @@ extends IterableOnce[T @uncheckedVariance]
563
567
def apply () = shared
564
568
def doesShareCombiners = true
565
569
} else new CombinerFactory [S , That ] {
566
- def apply () = cbf()
570
+ def apply () = {
571
+ val r = cbf()
572
+ r.combinerTaskSupport = tasksupport
573
+ r
574
+ }
567
575
def doesShareCombiners = false
568
576
}
569
577
}
Original file line number Diff line number Diff line change @@ -39,4 +39,13 @@ class TaskTest {
39
39
40
40
for (x <- one ; y <- two) assertEquals(" two" , Thread .currentThread.getName)
41
41
}
42
+
43
+ @ Test
44
+ def `t152 pass on task support` (): Unit = {
45
+ val myTs = new ExecutionContextTaskSupport ()
46
+ val c = List (1 ).par
47
+ c.tasksupport = myTs
48
+ val r = c.filter(_ != 0 ).map(_ + 1 )
49
+ assertSame(myTs, r.tasksupport)
50
+ }
42
51
}
You can’t perform that action at this time.
0 commit comments