Server IP : 185.86.78.101 / Your IP : 216.73.216.124 Web Server : Apache System : Linux 675867-vds-valikoshka1996.gmhost.pp.ua 5.4.0-150-generic #167-Ubuntu SMP Mon May 15 17:35:05 UTC 2023 x86_64 User : www ( 1000) PHP Version : 7.4.33 Disable Function : passthru,exec,system,putenv,chroot,chgrp,chown,shell_exec,popen,proc_open,pcntl_exec,ini_alter,ini_restore,dl,openlog,syslog,readlink,symlink,popepassthru,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_dispatch,pcntl_get_last_error,pcntl_strerror,pcntl_sigprocmask,pcntl_sigwaitinfo,pcntl_sigtimedwait,pcntl_exec,pcntl_getpriority,pcntl_setpriority,imap_open,apache_setenv MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /www/wwwroot/mifepriston.org/node_modules/rxjs/observable/ |
Upload File : |
import { IScheduler } from '../Scheduler'; import { Observable } from '../Observable'; import { Subscriber } from '../Subscriber'; import { Subscription } from '../Subscription'; export declare type ConditionFunc<S> = (state: S) => boolean; export declare type IterateFunc<S> = (state: S) => S; export declare type ResultFunc<S, T> = (state: S) => T; export interface GenerateBaseOptions<S> { /** * Initial state. */ initialState: S; /** * Condition function that accepts state and returns boolean. * When it returns false, the generator stops. * If not specified, a generator never stops. */ condition?: ConditionFunc<S>; /** * Iterate function that accepts state and returns new state. */ iterate: IterateFunc<S>; /** * IScheduler to use for generation process. * By default, a generator starts immediately. */ scheduler?: IScheduler; } export interface GenerateOptions<T, S> extends GenerateBaseOptions<S> { /** * Result selection function that accepts state and returns a value to emit. */ resultSelector: ResultFunc<S, T>; } /** * We need this JSDoc comment for affecting ESDoc. * @extends {Ignored} * @hide true */ export declare class GenerateObservable<T, S> extends Observable<T> { private initialState; private condition; private iterate; private resultSelector; private scheduler; constructor(initialState: S, condition: ConditionFunc<S>, iterate: IterateFunc<S>, resultSelector: ResultFunc<S, T>, scheduler?: IScheduler); /** * Generates an observable sequence by running a state-driven loop * producing the sequence's elements, using the specified scheduler * to send out observer messages. * * <img src="./img/generate.png" width="100%"> * * @example <caption>Produces sequence of 0, 1, 2, ... 9, then completes.</caption> * var res = Rx.Observable.generate(0, x => x < 10, x => x + 1, x => x); * * @example <caption>Using asap scheduler, produces sequence of 2, 3, 5, then completes.</caption> * var res = Rx.Observable.generate(1, x => x < 5, x => x * 2, x => x + 1, Rx.Scheduler.asap); * * @see {@link from} * @see {@link create} * * @param {S} initialState Initial state. * @param {function (state: S): boolean} condition Condition to terminate generation (upon returning false). * @param {function (state: S): S} iterate Iteration step function. * @param {function (state: S): T} resultSelector Selector function for results produced in the sequence. * @param {Scheduler} [scheduler] A {@link IScheduler} on which to run the generator loop. If not provided, defaults to emit immediately. * @returns {Observable<T>} The generated sequence. */ static create<T, S>(initialState: S, condition: ConditionFunc<S>, iterate: IterateFunc<S>, resultSelector: ResultFunc<S, T>, scheduler?: IScheduler): Observable<T>; /** * Generates an observable sequence by running a state-driven loop * producing the sequence's elements, using the specified scheduler * to send out observer messages. * The overload uses state as an emitted value. * * <img src="./img/generate.png" width="100%"> * * @example <caption>Produces sequence of 0, 1, 2, ... 9, then completes.</caption> * var res = Rx.Observable.generate(0, x => x < 10, x => x + 1); * * @example <caption>Using asap scheduler, produces sequence of 1, 2, 4, then completes.</caption> * var res = Rx.Observable.generate(1, x => x < 5, x => x * 2, Rx.Scheduler.asap); * * @see {@link from} * @see {@link create} * * @param {S} initialState Initial state. * @param {function (state: S): boolean} condition Condition to terminate generation (upon returning false). * @param {function (state: S): S} iterate Iteration step function. * @param {Scheduler} [scheduler] A {@link IScheduler} on which to run the generator loop. If not provided, defaults to emit immediately. * @returns {Observable<S>} The generated sequence. */ static create<S>(initialState: S, condition: ConditionFunc<S>, iterate: IterateFunc<S>, scheduler?: IScheduler): Observable<S>; /** * Generates an observable sequence by running a state-driven loop * producing the sequence's elements, using the specified scheduler * to send out observer messages. * The overload accepts options object that might contain initial state, iterate, * condition and scheduler. * * <img src="./img/generate.png" width="100%"> * * @example <caption>Produces sequence of 0, 1, 2, ... 9, then completes.</caption> * var res = Rx.Observable.generate({ * initialState: 0, * condition: x => x < 10, * iterate: x => x + 1 * }); * * @see {@link from} * @see {@link create} * * @param {GenerateBaseOptions<S>} options Object that must contain initialState, iterate and might contain condition and scheduler. * @returns {Observable<S>} The generated sequence. */ static create<S>(options: GenerateBaseOptions<S>): Observable<S>; /** * Generates an observable sequence by running a state-driven loop * producing the sequence's elements, using the specified scheduler * to send out observer messages. * The overload accepts options object that might contain initial state, iterate, * condition, result selector and scheduler. * * <img src="./img/generate.png" width="100%"> * * @example <caption>Produces sequence of 0, 1, 2, ... 9, then completes.</caption> * var res = Rx.Observable.generate({ * initialState: 0, * condition: x => x < 10, * iterate: x => x + 1, * resultSelector: x => x * }); * * @see {@link from} * @see {@link create} * * @param {GenerateOptions<T, S>} options Object that must contain initialState, iterate, resultSelector and might contain condition and scheduler. * @returns {Observable<T>} The generated sequence. */ static create<T, S>(options: GenerateOptions<T, S>): Observable<T>; /** @deprecated internal use only */ _subscribe(subscriber: Subscriber<any>): Subscription | Function | void; private static dispatch<T, S>(state); }