Package | Description |
---|---|
io.vertx.rxjava3.core |
Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<WorkerExecutor> |
WorkerExecutor.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
WorkerExecutor |
Vertx.createSharedWorkerExecutor(String name)
|
WorkerExecutor |
Vertx.createSharedWorkerExecutor(String name,
int poolSize)
|
WorkerExecutor |
Vertx.createSharedWorkerExecutor(String name,
int poolSize,
long maxExecuteTime)
Like
Vertx.createSharedWorkerExecutor(java.lang.String) but with the VertxOptions maxExecuteTimeUnit . |
WorkerExecutor |
Vertx.createSharedWorkerExecutor(String name,
int poolSize,
long maxExecuteTime,
TimeUnit maxExecuteTimeUnit)
Create a named worker executor, the executor should be closed when it's not needed anymore to release
resources.
This method can be called mutiple times with the same
name . |
static WorkerExecutor |
WorkerExecutor.newInstance(WorkerExecutor arg) |
Modifier and Type | Method and Description |
---|---|
static Scheduler |
RxHelper.blockingScheduler(WorkerExecutor executor)
Create a scheduler for a
WorkerExecutor object, actions are executed on the threads of this executor. |
Copyright © 2024 Eclipse. All rights reserved.