ronshapiro / rxjava-priority-scheduler

An RxJava scheduler that incorporates priorities in scheduling tasks
55 stars 6 forks source link

PriorityScheduler is not an instanceof Scheduler #1

Open ronshapiro opened 9 years ago

ronshapiro commented 9 years ago

Right now this is because .priority(int) should be called before any scheduling on the scheduler happens. Potential options are to make .priority(int) return this, and each time a new Scheduler.Worker is created, reset the priority back to a normal value, or to set it to an invalid value.