open class WorkerExecutor : Measured
An executor for executing blocking code in Vert.x .
It provides the same executeBlocking operation than io.vertx.reactivex.core.Context and io.vertx.reactivex.core.Vertx but on a separate worker pool.
NOTE: This class has been automatically generated from the io.vertx.core.WorkerExecutor non RX-ified interface using Vert.x codegen.
WorkerExecutor(delegate: WorkerExecutor) |
static val __TYPE_ARG: TypeArg<WorkerExecutor> |
open fun close(): Unit
Close the executor. |
|
open fun equals(other: Any?): Boolean |
|
open fun <T : Any> executeBlocking(blockingCodeHandler: Handler<Future<T>>, ordered: Boolean, resultHandler: Handler<AsyncResult<T>>): Unit
Safely execute some blocking code. Executes the blocking code in the handler When the code is complete the handler A In the open fun <T : Any> executeBlocking(blockingCodeHandler: Handler<Future<T>>, resultHandler: Handler<AsyncResult<T>>): Unit
Like |
|
open fun getDelegate(): WorkerExecutor |
|
open fun hashCode(): Int |
|
open fun isMetricsEnabled(): Boolean
Whether the metrics are enabled for this measured object |
|
open static fun newInstance(arg: WorkerExecutor): WorkerExecutor |
|
open fun <T : Any> rxExecuteBlocking(blockingCodeHandler: Handler<Future<T>>, ordered: Boolean): Single<T>
Safely execute some blocking code. Executes the blocking code in the handler When the code is complete the handler A In the open fun <T : Any> rxExecuteBlocking(blockingCodeHandler: Handler<Future<T>>): Single<T>
Like |
|
open fun toString(): String |