Class RxHelper

    • Constructor Detail

      • RxHelper

        public RxHelper()
    • Method Detail

      • scheduler

        public static Scheduler scheduler​(Vertx vertx)
        Create a scheduler for a Vertx object, actions are executed on the event loop.
        Parameters:
        vertx - the vertx object
        Returns:
        the scheduler
      • scheduler

        public static Scheduler scheduler​(Context context)
        Create a scheduler for a Context, actions are executed on the event loop of this context.
        Parameters:
        context - the context object
        Returns:
        the scheduler
      • blockingScheduler

        public static Scheduler blockingScheduler​(Vertx vertx)
        Create a scheduler for a Vertx object, actions can be blocking, they are not executed on Vertx event loop.
        Parameters:
        vertx - the vertx object
        Returns:
        the scheduler
      • blockingScheduler

        public static Scheduler blockingScheduler​(Vertx vertx,
                                                  boolean ordered)
        Create a scheduler for a Vertx object, actions can be blocking, they are not executed on Vertx event loop.
        Parameters:
        vertx - the vertx 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 scheduler
      • blockingScheduler

        public static Scheduler blockingScheduler​(WorkerExecutor executor)
        Create a scheduler for a WorkerExecutor object, actions are executed on the threads of this executor.
        Parameters:
        executor - the worker executor object
        Returns:
        the scheduler
      • toSubscriber

        public static <T> WriteStreamSubscriber<T> toSubscriber​(WriteStream<T> stream)
        Adapts a Vert.x WriteStream to an RxJava 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 Subscriber