Class CompletableOnSubscribeMerge

java.lang.Object
rx.internal.operators.CompletableOnSubscribeMerge
All Implemented Interfaces:
Completable.CompletableOnSubscribe, Action, Action1<Completable.CompletableSubscriber>, Function

public final class CompletableOnSubscribeMerge extends Object implements Completable.CompletableOnSubscribe
  • Field Details

    • source

      final Observable<Completable> source
    • maxConcurrency

      final int maxConcurrency
    • delayErrors

      final boolean delayErrors
  • Constructor Details

    • CompletableOnSubscribeMerge

      public CompletableOnSubscribeMerge(Observable<? extends Completable> source, int maxConcurrency, boolean delayErrors)
  • Method Details