Module mutiny.zero.flow.adapters
Package mutiny.zero.flow.adapters

Interface AdaptersToReactiveStreams

public interface AdaptersToReactiveStreams
Adapters from Flow types to Reactive Streams types.

  • Method Details

    • publisher

      static <T> org.reactivestreams.Publisher<T> publisher(Flow.Publisher<T> publisher)
      Convert a Flow.Publisher to a Publisher.
      Type Parameters:
      T - the items type
      Parameters:
      publisher - the publisher
      Returns:
      the wrapped publisher

    • subscriber

      static <T> org.reactivestreams.Subscriber<T> subscriber(Flow.Subscriber<T> subscriber)
      Convert a Flow.Subscriber to a Subscriber.
      Type Parameters:
      T - the items type
      Parameters:
      subscriber - the subscriber
      Returns:
      the wrapped subscriber

    • subscription

      static org.reactivestreams.Subscription subscription(Flow.Subscription subscription)
      Convert a Flow.Subscription to a Subscription.
      Parameters:
      subscription - the subscription
      Returns:
      the wrapped subscription

    • processor

      static <T, R> org.reactivestreams.Processor<T,R> processor(Flow.Processor<T,R> processor)
      Convert a Flow.Processor to a Processor.
      Type Parameters:
      T - the items type
      R - the output items type
      Parameters:
      processor - the processor
      Returns:
      the wrapped processor