Class CompletableOnSubscribeMerge

    • Field Detail

      • maxConcurrency

        final int maxConcurrency
      • delayErrors

        final boolean delayErrors
    • Constructor Detail

      • CompletableOnSubscribeMerge

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

      • collectErrors

        public static java.lang.Throwable collectErrors​(java.util.Queue<java.lang.Throwable> q)
        Collects the Throwables from the queue, adding subsequent Throwables as suppressed to the first Throwable and returns it.
        Parameters:
        q - the queue to drain
        Returns:
        the Throwable containing all other Throwables as suppressed