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

Interface AdaptersToFlow

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

  • Method Details

    • publisher

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

    • subscriber

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

    • subscription

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

    • processor

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