Package hu.akarnokd.rxjava3.schedulers

Class SharedScheduler

java.lang.Object

io.reactivex.rxjava3.core.Scheduler

hu.akarnokd.rxjava3.schedulers.SharedScheduler

public final class SharedScheduler
extends Scheduler

A Scheduler implementation that uses one of the Workers from another Scheduler and shares the access to it through its own Workers.

Disposing a worker doesn't dispose the underlying shared worker so other workers of this class can continue their work; use shutdown() to release the underlying shared worker.

This scheduler doesn't support Scheduler.start() (it's a no-op) and once shutdown() it can't be revived.

Since:

0.6.2

Nested Class Summary

Nested classes/interfaces inherited from class io.reactivex.rxjava3.core.Scheduler

Scheduler.Worker

Constructor Summary

Constructors

Constructor	Description
SharedScheduler(Scheduler other)	Constructs a SharedScheduler and asks for a Worker from the provided other Scheduler.
SharedScheduler(Scheduler.Worker worker)	Constructs a SharedScheduler and uses the Worker instance provided.

Method Summary

Modifier and Type	Method	Description
Scheduler.Worker	createWorker()
long	now(java.util.concurrent.TimeUnit unit)
Disposable	scheduleDirect(java.lang.Runnable run)
Disposable	scheduleDirect(java.lang.Runnable run, long delay, java.util.concurrent.TimeUnit unit)
Disposable	schedulePeriodicallyDirect(java.lang.Runnable run, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	shutdown()

Methods inherited from class io.reactivex.rxjava3.core.Scheduler

clockDriftTolerance, start, when

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SharedScheduler

public SharedScheduler(Scheduler other)

Constructs a SharedScheduler and asks for a Worker from the provided other Scheduler.

Parameters:

other - the other Scheduler instance, not null

SharedScheduler

public SharedScheduler(Scheduler.Worker worker)

Constructs a SharedScheduler and uses the Worker instance provided.

Parameters:

worker - the worker to use, not null

Method Detail

shutdown

public void shutdown()

Overrides:

shutdown in class Scheduler

scheduleDirect

public Disposable scheduleDirect(java.lang.Runnable run)

Overrides:

scheduleDirect in class Scheduler

scheduleDirect

public Disposable scheduleDirect(java.lang.Runnable run,
                                 long delay,
                                 java.util.concurrent.TimeUnit unit)

Overrides:

scheduleDirect in class Scheduler

schedulePeriodicallyDirect

public Disposable schedulePeriodicallyDirect(java.lang.Runnable run,
                                             long initialDelay,
                                             long period,
                                             java.util.concurrent.TimeUnit unit)

Overrides:

schedulePeriodicallyDirect in class Scheduler

now

public long now(java.util.concurrent.TimeUnit unit)

Overrides:

now in class Scheduler

createWorker

public Scheduler.Worker createWorker()

Specified by:

createWorker in class Scheduler