Interface AdaptersToReactiveStreams


  • public interface AdaptersToReactiveStreams
    Adapters from Flow types to Reactive Streams types.
    • Method Summary

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

      • publisher

        static <T> org.reactivestreams.Publisher<T> publisher​(java.util.concurrent.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​(java.util.concurrent.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​(java.util.concurrent.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​(java.util.concurrent.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