Skip to content

Commit 46d3c66

Browse files
degreeOfParallelism() -> parallelism()
#997 (comment)
1 parent e797905 commit 46d3c66

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

rxjava-core/src/main/java/rx/Scheduler.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ public long now() {
128128
*
129129
* @return the scheduler's available degree of parallelism
130130
*/
131-
public int degreeOfParallelism() {
131+
public int parallelism() {
132132
return Runtime.getRuntime().availableProcessors();
133133
}
134134

rxjava-core/src/main/java/rx/operators/OperatorParallel.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -34,7 +34,7 @@ public final class OperatorParallel<T, R> implements Operator<R, T> {
3434
public OperatorParallel(Func1<Observable<T>, Observable<R>> f, Scheduler scheduler) {
3535
this.scheduler = scheduler;
3636
this.f = f;
37-
this.degreeOfParallelism = scheduler.degreeOfParallelism();
37+
this.degreeOfParallelism = scheduler.parallelism();
3838
}
3939

4040
@Override

0 commit comments

Comments
 (0)