Class FlowAdapters.FlowToReactiveSubscription

  • All Implemented Interfaces:
    java.util.concurrent.Flow.Subscription
    Enclosing class:
    FlowAdapters

    static final class FlowAdapters.FlowToReactiveSubscription
    extends java.lang.Object
    implements java.util.concurrent.Flow.Subscription
    Wraps a Reactive Streams Subscription and converts the calls to a Flow Subscription.
    • Constructor Detail

      • FlowToReactiveSubscription

        public FlowToReactiveSubscription​(Subscription reactive)
    • Method Detail

      • request

        public void request​(long n)
        Specified by:
        request in interface java.util.concurrent.Flow.Subscription
      • cancel

        public void cancel()
        Specified by:
        cancel in interface java.util.concurrent.Flow.Subscription