We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 255d9e2 commit 2144fe4Copy full SHA for 2144fe4
rxjava-core/src/test/java/rx/schedulers/ExecutorSchedulerTest.java
@@ -18,13 +18,16 @@
18
import rx.Scheduler;
19
import rx.internal.util.RxThreadFactory;
20
21
+import java.util.concurrent.Executor;
22
import java.util.concurrent.Executors;
23
24
public class ExecutorSchedulerTest extends AbstractSchedulerConcurrencyTests {
25
26
+ final static Executor executor = Executors.newFixedThreadPool(2, new RxThreadFactory("TestCustomPool-"));
27
+
28
@Override
29
protected Scheduler getScheduler() {
- return Schedulers.from(Executors.newFixedThreadPool(2, new RxThreadFactory("TestCustomPool-")));
30
+ return Schedulers.from(executor);
31
}
32
33
0 commit comments