Class ParallelFromPublisher.ParallelDispatcher.RailSubscription

java.lang.Object
io.reactivex.rxjava3.internal.operators.parallel.ParallelFromPublisher.ParallelDispatcher.RailSubscription
All Implemented Interfaces:
org.reactivestreams.Subscription
Enclosing class:
ParallelFromPublisher.ParallelDispatcher<T>

final class ParallelFromPublisher.ParallelDispatcher.RailSubscription extends Object implements org.reactivestreams.Subscription
  • Field Details

    • j

      final int j
    • m

      final int m
  • Constructor Details

    • RailSubscription

      RailSubscription(int j, int m)
  • Method Details

    • request

      public void request(long n)
      Specified by:
      request in interface org.reactivestreams.Subscription
    • cancel

      public void cancel()
      Specified by:
      cancel in interface org.reactivestreams.Subscription