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

Interface AdaptersToFlow

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

    • Method Summary

      Static Methods 
      Modifier and Type Method Description
      static <T,​R>
      java.util.concurrent.Flow.Processor<T,​R>      		 processor​(org.reactivestreams.Processor<T,​R> processor)
      Convert a Processor to a Flow.Processor.
      static <T> java.util.concurrent.Flow.Publisher<T> publisher​(org.reactivestreams.Publisher<T> publisher)
      Convert a Publisher to a Flow.Publisher.
      static <T> java.util.concurrent.Flow.Subscriber<T> subscriber​(org.reactivestreams.Subscriber<T> subscriber)
      Convert a Subscriber to a Flow.Subscriber.
      static java.util.concurrent.Flow.Subscription subscription​(org.reactivestreams.Subscription subscription)
      Convert a Subscription to a Flow.Subscription.

    • Method Detail

      • publisher

        static <T> java.util.concurrent.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> java.util.concurrent.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 java.util.concurrent.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> java.util.concurrent.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