Module mutiny.zero.vertxpublishers
Package mutiny.zero.vertxpublishers

Interface VertxPublisher

public interface VertxPublisher
Expose Vert.x streams as Reactive Streams compliant publishers.

  • Method Summary

    Static Methods
    Modifier and Type
    Method
    Description
    static <T> Flow.Publisher<T>
    fromFuture(Supplier<io.vertx.core.Future<? extends io.vertx.core.streams.ReadStream<T>>> futureStreamSupplier)
    Create a publisher from a Vert.x future stream supplier.
    static <T> Flow.Publisher<T>
    fromSupplier(Supplier<io.vertx.core.streams.ReadStream<T>> streamSupplier)
    Create a publisher from a Vert.x stream supplier.

  • Method Details

    • fromSupplier

      static <T> Flow.Publisher<T> fromSupplier(Supplier<io.vertx.core.streams.ReadStream<T>> streamSupplier)
      Create a publisher from a Vert.x stream supplier. The supplier is called for each new publisher subscription.
      Type Parameters:
      T - the elements type
      Parameters:
      streamSupplier - the ReadStream supplier, cannot be null, cannot return null, must not throw an exception
      Returns:
      the new Flow.Publisher

    • fromFuture

      static <T> Flow.Publisher<T> fromFuture(Supplier<io.vertx.core.Future<? extends io.vertx.core.streams.ReadStream<T>>> futureStreamSupplier)
      Create a publisher from a Vert.x future stream supplier. The supplier is called for each new publisher subscription.
      Type Parameters:
      T - the elements type
      Parameters:
      futureStreamSupplier - the Future ReadStream supplier, cannot be null, cannot return null, must not throw an exception
      Returns:
      the new Flow.Publisher