public class RxJavaEventExecutorGroupScheduler extends Scheduler
EventExecutorGroup
instance to schedule tasks. This should typically be used as a
computation scheduler or any other scheduler that do not schedule blocking tasks. See also
https://github.com/ReactiveX/RxNetty
/blob/0.5.x/rxnetty-common/src/main/java/io/reactivex/netty/threads/RxJavaEventloopScheduler.javaScheduler.Worker
Constructor and Description |
---|
RxJavaEventExecutorGroupScheduler(EventExecutorGroup eventLoopGroup) |
Modifier and Type | Method and Description |
---|---|
Scheduler.Worker |
createWorker() |
public RxJavaEventExecutorGroupScheduler(EventExecutorGroup eventLoopGroup)
public Scheduler.Worker createWorker()
createWorker
in class Scheduler
Copyright © 2018 lettuce.io. All rights reserved.