Graybyt3 Was Here

Linux vps-4656817-x.dattaweb.com 5.14.0-570.33.2.el9_6.x86_64 #1 SMP PREEMPT_DYNAMIC Thu Aug 14 07:37:35 EDT 2025 x86_64
Apache
200.58.107.103

File Name : race.ts

import { Observable } from '../Observable';
import { innerFrom } from './innerFrom';
import { Subscription } from '../Subscription';
import { ObservableInput, ObservableInputTuple } from '../types';
import { argsOrArgArray } from '../util/argsOrArgArray';
import { createOperatorSubscriber } from '../operators/OperatorSubscriber';
import { Subscriber } from '../Subscriber';

export function race<T extends readonly unknown[]>(inputs: [...ObservableInputTuple<T>]): Observable<T[number]>;
export function race<T extends readonly unknown[]>(...inputs: [...ObservableInputTuple<T>]): Observable<T[number]>;

/**
 * Returns an observable that mirrors the first source observable to emit an item.
 *
 * ![](race.png)
 *
 * `race` returns an observable, that when subscribed to, subscribes to all source observables immediately.
 * As soon as one of the source observables emits a value, the result unsubscribes from the other sources.
 * The resulting observable will forward all notifications, including error and completion, from the "winning"
 * source observable.
 *
 * If one of the used source observable throws an errors before a first notification
 * the race operator will also throw an error, no matter if another source observable
 * could potentially win the race.
 *
 * `race` can be useful for selecting the response from the fastest network connection for
 * HTTP or WebSockets. `race` can also be useful for switching observable context based on user
 * input.
 *
 * ## Example
 *
 * Subscribes to the observable that was the first to start emitting.
 *
 * ```ts
 * import { interval, map, race } from 'rxjs';
 *
 * const obs1 = interval(7000).pipe(map(() => 'slow one'));
 * const obs2 = interval(3000).pipe(map(() => 'fast one'));
 * const obs3 = interval(5000).pipe(map(() => 'medium one'));
 *
 * race(obs1, obs2, obs3)
 *   .subscribe(winner => console.log(winner));
 *
 * // Outputs
 * // a series of 'fast one'
 * ```
 *
 * @param {...Observables} ...observables sources used to race for which Observable emits first.
 * @return {Observable} an Observable that mirrors the output of the first Observable to emit an item.
 */
export function race<T>(...sources: (ObservableInput<T> | ObservableInput<T>[])[]): Observable<any> {
  sources = argsOrArgArray(sources);
  // If only one source was passed, just return it. Otherwise return the race.
  return sources.length === 1 ? innerFrom(sources[0] as ObservableInput<T>) : new Observable<T>(raceInit(sources as ObservableInput<T>[]));
}

/**
 * An observable initializer function for both the static version and the
 * operator version of race.
 * @param sources The sources to race
 */
export function raceInit<T>(sources: ObservableInput<T>[]) {
  return (subscriber: Subscriber<T>) => {
    let subscriptions: Subscription[] = [];

// Subscribe to all of the sources. Note that we are checking `subscriptions` here
    // Is is an array of all actively "racing" subscriptions, and it is `null` after the
    // race has been won. So, if we have racer that synchronously "wins", this loop will
    // stop before it subscribes to any more.
    for (let i = 0; subscriptions && !subscriber.closed && i < sources.length; i++) {
      subscriptions.push(
        innerFrom(sources[i] as ObservableInput<T>).subscribe(
          createOperatorSubscriber(subscriber, (value) => {
            if (subscriptions) {
              // We're still racing, but we won! So unsubscribe
              // all other subscriptions that we have, except this one.
              for (let s = 0; s < subscriptions.length; s++) {
                s !== i && subscriptions[s].unsubscribe();
              }
              subscriptions = null!;
            }
            subscriber.next(value);
          })
        )
      );
    }
  };
}

System Information
*ReClick For Close
File : BlackDragon /acciones/about.php

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	bienesraicess/bienesraicess	0755	2025-09-01 07:16:35
..	dir	-	bienesraicess/bienesraicess	0755	2025-09-01 07:16:34
dom	dir	-	bienesraicess/bienesraicess	0755	2025-09-01 07:16:34
ConnectableObservable.ts	file	3.5 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
bindCallback.ts	file	6.64 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
bindCallbackInternals.ts	file	4.83 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
bindNodeCallback.ts	file	5.85 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
combineLatest.ts	file	13.1 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
concat.ts	file	4.42 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
connectable.ts	file	2.29 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
defer.ts	file	2.26 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
empty.ts	file	2.17 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
forkJoin.ts	file	8.02 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
from.ts	file	2.94 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
fromEvent.ts	file	14.2 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
fromEventPattern.ts	file	6.69 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
fromSubscribable.ts	file	559 B	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
generate.ts	file	12.18 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:32
iif.ts	file	2.48 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
innerFrom.ts	file	4.67 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
interval.ts	file	1.84 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
merge.ts	file	4.32 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
never.ts	file	1.16 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
of.ts	file	2.74 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
onErrorResumeNext.ts	file	3.4 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
pairs.ts	file	2.76 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
partition.ts	file	3.45 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
race.ts	file	3.7 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
range.ts	file	2.68 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:33
throwError.ts	file	4.36 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:34
timer.ts	file	6.89 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:34
using.ts	file	2.9 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:34
zip.ts	file	4.68 KB	bienesraicess/bienesraicess	0644	2025-09-01 07:16:35