byp4a55 professor6T9

Linux server800.serverconfig.center 6.1.0-48-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.172-1 (2026-05-15) x86_64
Apache
195.242.103.230

File Name : onErrorResumeNext.ts

import { Observable } from '../Observable';
import { ObservableInputTuple } from '../types';
import { argsOrArgArray } from '../util/argsOrArgArray';
import { OperatorSubscriber } from '../operators/OperatorSubscriber';
import { noop } from '../util/noop';
import { innerFrom } from './innerFrom';

/* tslint:disable:max-line-length */
export function onErrorResumeNext<A extends readonly unknown[]>(sources: [...ObservableInputTuple<A>]): Observable<A[number]>;
export function onErrorResumeNext<A extends readonly unknown[]>(...sources: [...ObservableInputTuple<A>]): Observable<A[number]>;

/* tslint:enable:max-line-length */

/**
 * When any of the provided Observable emits a complete or an error notification, it immediately subscribes to the next one
 * that was passed.
 *
 * <span class="informal">Execute series of Observables no matter what, even if it means swallowing errors.</span>
 *
 * ![](onErrorResumeNext.png)
 *
 * `onErrorResumeNext` will subscribe to each observable source it is provided, in order.
 * If the source it's subscribed to emits an error or completes, it will move to the next source
 * without error.
 *
 * If `onErrorResumeNext` is provided no arguments, or a single, empty array, it will return {@link EMPTY}.
 *
 * `onErrorResumeNext` is basically {@link concat}, only it will continue, even if one of its
 * sources emits an error.
 *
 * Note that there is no way to handle any errors thrown by sources via the result of
 * `onErrorResumeNext`. If you want to handle errors thrown in any given source, you can
 * always use the {@link catchError} operator on them before passing them into `onErrorResumeNext`.
 *
 * ## Example
 *
 * Subscribe to the next Observable after map fails
 *
 * ```ts
 * import { onErrorResumeNext, of, map } from 'rxjs';
 *
 * onErrorResumeNext(
 *   of(1, 2, 3, 0).pipe(
 *     map(x => {
 *       if (x === 0) {
 *         throw Error();
 *       }
 *       return 10 / x;
 *     })
 *   ),
 *   of(1, 2, 3)
 * )
 * .subscribe({
 *   next: value => console.log(value),
 *   error: err => console.log(err),     // Will never be called.
 *   complete: () => console.log('done')
 * });
 *
 * // Logs:
 * // 10
 * // 5
 * // 3.3333333333333335
 * // 1
 * // 2
 * // 3
 * // 'done'
 * ```
 *
 * @see {@link concat}
 * @see {@link catchError}
 *
 * @param {...ObservableInput} sources Observables (or anything that *is* observable) passed either directly or as an array.
 * @return {Observable} An Observable that concatenates all sources, one after the other,
 * ignoring all errors, such that any error causes it to move on to the next source.
 */
export function onErrorResumeNext<A extends readonly unknown[]>(
  ...sources: [[...ObservableInputTuple<A>]] | [...ObservableInputTuple<A>]
): Observable<A[number]> {
  const nextSources: ObservableInputTuple<A> = argsOrArgArray(sources) as any;

return new Observable((subscriber) => {
    let sourceIndex = 0;
    const subscribeNext = () => {
      if (sourceIndex < nextSources.length) {
        let nextSource: Observable<A[number]>;
        try {
          nextSource = innerFrom(nextSources[sourceIndex++]);
        } catch (err) {
          subscribeNext();
          return;
        }
        const innerSubscriber = new OperatorSubscriber(subscriber, undefined, noop, noop);
        nextSource.subscribe(innerSubscriber);
        innerSubscriber.add(subscribeNext);
      } else {
        subscriber.complete();
      }
    };
    subscribeNext();
  });
}

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
..	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
dom	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
ConnectableObservable.ts	text/x-java	3.5 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
bindCallback.ts	text/x-java	6.64 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
bindCallbackInternals.ts	text/x-java	4.83 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
bindNodeCallback.ts	text/x-java	5.85 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
combineLatest.ts	text/x-java	13.1 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
concat.ts	text/x-java	4.42 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
connectable.ts	text/x-java	2.29 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
defer.ts	text/x-java	2.26 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
empty.ts	text/x-java	2.17 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
forkJoin.ts	text/x-java	8.02 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
from.ts	text/html	2.94 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
fromEvent.ts	text/x-java	14.2 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
fromEventPattern.ts	text/x-java	6.69 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
fromSubscribable.ts	text/x-java	559 B	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
generate.ts	text/x-java	12.18 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
iif.ts	text/x-java	2.48 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
innerFrom.ts	text/x-java	4.67 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
interval.ts	text/x-java	1.84 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
merge.ts	text/x-java	4.32 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
never.ts	text/x-java	1.16 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
of.ts	text/x-java	2.74 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
onErrorResumeNext.ts	text/x-java	3.4 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
pairs.ts	text/x-java	2.76 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
partition.ts	text/x-java	3.45 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
race.ts	text/x-java	3.7 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
range.ts	text/x-java	2.68 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
throwError.ts	text/x-java	4.36 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
timer.ts	text/x-java	6.89 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
using.ts	text/x-java	2.9 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
zip.ts	text/x-java	4.68 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34

Team Anon Force

https://t.me/Professor6T9x