File tree Expand file tree Collapse file tree 5 files changed +10
-10
lines changed
language-adaptors/rxjava-scala/src/main/scala/rx/lang/scala Expand file tree Collapse file tree 5 files changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -35,7 +35,7 @@ trait Scheduler {
35
35
*
36
36
* @return the scheduler's available degree of parallelism.
37
37
*/
38
- def degreeOfParallelism : Int = asJavaScheduler.degreeOfParallelism
38
+ def parallelism : Int = asJavaScheduler.parallelism()
39
39
40
40
/**
41
41
* @return the scheduler's notion of current absolute time in milliseconds.
Original file line number Diff line number Diff line change @@ -5,13 +5,13 @@ import rx.lang.scala.Scheduler
5
5
6
6
object ComputationScheduler {
7
7
/**
8
- * {@link Scheduler} intended for computational work.
8
+ * [[ rx.lang.scala. Scheduler]] intended for computational work.
9
9
* <p>
10
10
* This can be used for event-loops, processing callbacks and other computational work.
11
11
* <p>
12
- * Do not perform IO-bound work on this scheduler. Use {@link IOScheduler()} instead.
12
+ * Do not perform IO-bound work on this scheduler. Use [[ rx.lang.scala.schedulers. IOScheduler]] instead.
13
13
*
14
- * @return { @link Scheduler} for computation-bound work.
14
+ * @return [[ rx.lang.scala. Scheduler]] for computation-bound work.
15
15
*/
16
16
def apply (): ComputationScheduler = {
17
17
new ComputationScheduler (rx.schedulers.Schedulers .computation())
Original file line number Diff line number Diff line change @@ -19,15 +19,15 @@ import rx.lang.scala.Scheduler
19
19
20
20
object IOScheduler {
21
21
/**
22
- * {@link Scheduler} intended for IO-bound work.
22
+ * [[ rx.lang.scala. Scheduler]] intended for IO-bound work.
23
23
* <p>
24
- * The implementation is backed by an {@link Executor} thread-pool that will grow as needed.
24
+ * The implementation is backed by an ` Executor` thread-pool that will grow as needed.
25
25
* <p>
26
26
* This can be used for asynchronously performing blocking IO.
27
27
* <p>
28
- * Do not perform computational work on this scheduler. Use {@link ComputationScheduler()} instead.
28
+ * Do not perform computational work on this scheduler. Use [[ rx.lang.scala.schedulers. ComputationScheduler]] instead.
29
29
*
30
- * @return { @link ExecutorScheduler} for IO-bound work.
30
+ * @return [[ rx.lang.scala.Scheduler ]] for IO-bound work
31
31
*/
32
32
def apply (): IOScheduler = {
33
33
new IOScheduler (rx.schedulers.Schedulers .io)
Original file line number Diff line number Diff line change @@ -20,7 +20,7 @@ import rx.lang.scala.Scheduler
20
20
object NewThreadScheduler {
21
21
22
22
/**
23
- * Returns a [[rx.lang.scala.Scheduler ]] that creates a new {@link Thread} for each unit of work.
23
+ * Returns a [[rx.lang.scala.Scheduler ]] that creates a new `java.lang. Thread` for each unit of work.
24
24
*/
25
25
def apply (): NewThreadScheduler = {
26
26
new NewThreadScheduler (rx.schedulers.Schedulers .newThread())
Original file line number Diff line number Diff line change @@ -4,7 +4,7 @@ import rx.lang.scala.Scheduler
4
4
5
5
object TrampolineScheduler {
6
6
/**
7
- * {@link Scheduler} that queues work on the current thread to be executed after the current work completes.
7
+ * [[ rx.lang.scala. Scheduler]] that queues work on the current thread to be executed after the current work completes.
8
8
*/
9
9
def apply (): TrampolineScheduler = {
10
10
new TrampolineScheduler (rx.schedulers.Schedulers .trampoline())
You can’t perform that action at this time.
0 commit comments