Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
add	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
observable	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
operator	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
operators	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
scheduler	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
symbol	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
testing	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
util	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
AsyncSubject.ts	1.04 KB	-rw-rw-r--	2022-08-30 11:49
BUILD.bazel	650 B	-rw-rw-r--	2022-08-30 11:49
BehaviorSubject.ts	962 B	-rw-rw-r--	2022-08-30 11:49
InnerSubscriber.ts	742 B	-rw-rw-r--	2022-08-30 11:49
LICENSE.txt	10.8 KB	-rw-rw-r--	2022-08-30 11:49
MiscJSDoc.ts	15.3 KB	-rw-rw-r--	2022-08-30 11:49
Notification.ts	4.32 KB	-rw-rw-r--	2022-08-30 11:49
Observable.ts	14.9 KB	-rw-rw-r--	2022-08-30 11:49
Observer.ts	828 B	-rw-rw-r--	2022-08-30 11:49
Operator.ts	191 B	-rw-rw-r--	2022-08-30 11:49
OuterSubscriber.ts	646 B	-rw-rw-r--	2022-08-30 11:49
README.md	7.27 KB	-rw-rw-r--	2022-08-30 11:49
ReplaySubject.ts	2.94 KB	-rw-rw-r--	2022-08-30 11:49
Rx.global.js	137 B	-rw-rw-r--	2022-08-30 11:49
Rx.ts	8.16 KB	-rw-rw-r--	2022-08-30 11:49
Scheduler.ts	2.29 KB	-rw-rw-r--	2022-08-30 11:49
Subject.ts	4.04 KB	-rw-rw-r--	2022-08-30 11:49
SubjectSubscription.ts	849 B	-rw-rw-r--	2022-08-30 11:49
Subscriber.ts	8.63 KB	-rw-rw-r--	2022-08-30 11:49
Subscription.ts	7.08 KB	-rw-rw-r--	2022-08-30 11:49
WORKSPACE	25 B	-rw-rw-r--	2022-08-30 11:49
interfaces.ts	294 B	-rw-rw-r--	2022-08-30 11:49
operators.ts	5.27 KB	-rw-rw-r--	2022-08-30 11:49
tsconfig.json	640 B	-rw-rw-r--	2022-08-30 11:49

Rename

import { Action } from './scheduler/Action';
import { Subscription } from './Subscription';

export interface IScheduler {
  now(): number;
  schedule<T>(work: (this: Action<T>, state?: T) => void, delay?: number, state?: T): Subscription;
}
/**
 * An execution context and a data structure to order tasks and schedule their
 * execution. Provides a notion of (potentially virtual) time, through the
 * `now()` getter method.
 *
 * Each unit of work in a Scheduler is called an {@link Action}.
 *
 * ```ts
 * class Scheduler {
 *   now(): number;
 *   schedule(work, delay?, state?): Subscription;
 * }
 * ```
 *
 * @class Scheduler
 */
export class Scheduler implements IScheduler {

public static now: () => number = Date.now ? Date.now : () => +new Date();

constructor(private SchedulerAction: typeof Action,
              now: () => number = Scheduler.now) {
    this.now = now;
  }

/**
   * A getter method that returns a number representing the current time
   * (at the time this function was called) according to the scheduler's own
   * internal clock.
   * @return {number} A number that represents the current time. May or may not
   * have a relation to wall-clock time. May or may not refer to a time unit
   * (e.g. milliseconds).
   */
  public now: () => number;

/**
   * Schedules a function, `work`, for execution. May happen at some point in
   * the future, according to the `delay` parameter, if specified. May be passed
   * some context object, `state`, which will be passed to the `work` function.
   *
   * The given arguments will be processed an stored as an Action object in a
   * queue of actions.
   *
   * @param {function(state: ?T): ?Subscription} work A function representing a
   * task, or some unit of work to be executed by the Scheduler.
   * @param {number} [delay] Time to wait before executing the work, where the
   * time unit is implicit and defined by the Scheduler itself.
   * @param {T} [state] Some contextual data that the `work` function uses when
   * called by the Scheduler.
   * @return {Subscription} A subscription in order to be able to unsubscribe
   * the scheduled work.
   */
  public schedule<T>(work: (this: Action<T>, state?: T) => void, delay: number = 0, state?: T): Subscription {
    return new this.SchedulerAction<T>(this, work).schedule(state, delay);
  }
}