net.bluemind.lib.vertx

Class BlockingCode

java.lang.Object

net.bluemind.lib.vertx.BlockingCode

public class BlockingCode
extends java.lang.Object

Helper inspired by vertx 3 to run blocking code from an event loop context.

Method Summary

Modifier and Type	Method and Description
static BlockingCode	forVertx(org.vertx.java.core.Vertx v) Creates a BlockingCode executor to use in a vertx event loop.
<T> java.util.concurrent.CompletableFuture<T>	run(java.util.function.Supplier<T> supplier) Returns a future that will execute its followers in the vertx context associated with this instance
BlockingCode	withExecutor(java.util.concurrent.ExecutorService pool) Provide your own executor where the blocking code will run.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

withExecutor

public BlockingCode withExecutor(java.util.concurrent.ExecutorService pool)

Provide your own executor where the blocking code will run.

Parameters:

pool -

Returns:

forVertx

public static BlockingCode forVertx(org.vertx.java.core.Vertx v)

Creates a BlockingCode executor to use in a vertx event loop. DISCLAIMER: Do not call that with VertxPlatform.getVertx() but with the vertx instance from your verticle

Parameters:

v -

Returns:

run

public <T> java.util.concurrent.CompletableFuture<T> run(java.util.function.Supplier<T> supplier)

Returns a future that will execute its followers in the vertx context associated with this instance

Parameters:

supplier -

Returns:

a future for with the result of the given supplier