Class MutinyHelper


  • public class MutinyHelper
    extends Object
    • Constructor Detail

      • MutinyHelper

        public MutinyHelper()
    • Method Detail

      • executor

        public static Executor executor​(io.vertx.core.Vertx vertx)
        Create an executor for a Vertx object, actions are executed on the event loop.
        Parameters:
        vertx - the vert.x object
        Returns:
        the executor
      • executor

        public static Executor executor​(io.vertx.core.Context context)
        Create an executor for a Context, actions are executed on the event loop of this context.
        Parameters:
        context - the context object
        Returns:
        the executor
      • blockingExecutor

        public static Executor blockingExecutor​(io.vertx.core.Vertx vertx)
        Create an executor for a Vertx object, actions can be blocking, they are not executed on Vert.x event loop.
        Parameters:
        vertx - the ver.tx object
        Returns:
        the executor
      • blockingExecutor

        public static Executor blockingExecutor​(io.vertx.core.Vertx vertx,
                                                boolean ordered)
        Create an executor for a Vertx object, actions can be blocking, they are not executed on Ver.tx event loop.
        Parameters:
        vertx - the vert.x object
        ordered - if true then if when tasks are scheduled several times on the same context, the executions for that context will be executed serially, not in parallel. if false then they will be no ordering guarantees
        Returns:
        the executor
      • blockingExecutor

        public static Executor blockingExecutor​(io.vertx.core.WorkerExecutor worker)
        Create a scheduler for a WorkerExecutor object, actions are executed on the threads of this executor.
        Parameters:
        worker - the worker executor object
        Returns:
        the executor
      • unwrap

        public static Class unwrap​(Class<?> type)
        Unwrap the type used in Mutiny.
        Parameters:
        type - the type to unwrap
        Returns:
        the unwrapped type
      • toSubscriber

        public static <T> WriteStreamSubscriber<T> toSubscriber​(io.vertx.core.streams.WriteStream<T> stream)
        Adapts a Vert.x WriteStream to a Mutiny Flow.Subscriber.

        After subscription, the original WriteStream handlers should not be used anymore as they will be used by the adapter.

        Parameters:
        stream - the stream to adapt
        Returns:
        the adapted Flow.Subscriber