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 Summary
Fields -
Constructor Summary
Constructors -
Method Summary
-
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 interfaceorg.reactivestreams.Subscription
-
cancel
public void cancel()- Specified by:
cancel
in interfaceorg.reactivestreams.Subscription
-