rxjava-priority-scheduler

rxjava-priority-scheduler copied to clipboard

porting into rxjava2

1

isfaaghyth

porting to rxjava2

2

thanks for your good job, i have used this lib in many project. rxjava2 is stable now, would you porting this lib to it? i just have a try: https://github.com/skyLiao/rxjava-priority-scheduler/tree/rxjava2,...

skyLiao

Implementing PriorityScheduler based on ExecutorScheduler

4

@ronshapiro, what do you think about implementation of PriorityScheduler which is based on standard ExecutorScheduler? There might be a `PriorityBlockingQueue` accepting `PriorityExecutorAction`s as a repacement for ExecutorScheduler's `ConcurrentLinkedQueue` with `ExecutorAction`.

NorseDreki

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`...

ronshapiro