Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
backpressure	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
concurrency	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
disposables	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
internal	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
joins	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
linq	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
subjects	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
testing	[ DIR ]	drwxrwxr-x	2022-08-30 11:49
abstractobserver.ts	1.64 KB	-rw-rw-r--	2022-08-30 11:49
anonymousobservable.ts	287 B	-rw-rw-r--	2022-08-30 11:49
anonymousobserver.ts	1.42 KB	-rw-rw-r--	2022-08-30 11:49
checkedobserver.ts	338 B	-rw-rw-r--	2022-08-30 11:49
es5.ts	930 B	-rw-rw-r--	2022-08-30 11:49
es6-iterable.d.ts	5.23 KB	-rw-rw-r--	2022-08-30 11:49
es6-promise.d.ts	3.72 KB	-rw-rw-r--	2022-08-30 11:49
es6.ts	844 B	-rw-rw-r--	2022-08-30 11:49
notification.ts	3.86 KB	-rw-rw-r--	2022-08-30 11:49
observable.ts	7.9 KB	-rw-rw-r--	2022-08-30 11:49
observer-extras.ts	2.62 KB	-rw-rw-r--	2022-08-30 11:49
observer-lite.ts	2.41 KB	-rw-rw-r--	2022-08-30 11:49
observer.ts	280 B	-rw-rw-r--	2022-08-30 11:49
scheduledobserver.ts	310 B	-rw-rw-r--	2022-08-30 11:49

Rename

/// <reference path="./disposables/disposable.ts" />
/// <reference path="./concurrency/scheduler.ts" />
/// <reference path="./observable.ts" />
/// <reference path="./observer-lite.ts" />
module Rx {
    /**
     *  Represents a notification to an observer.
     */
    export interface Notification<T> {
        /**
         * Invokes the delegate corresponding to the notification or the observer's method corresponding to the notification and returns the produced result.
         *
         * @memberOf Notification
         * @param {Any} observerOrOnNext Delegate to invoke for an OnNext notification or Observer to invoke the notification on..
         * @param {Function} onError Delegate to invoke for an OnError notification.
         * @param {Function} onCompleted Delegate to invoke for an OnCompleted notification.
         * @returns {Any} Result produced by the observation.
         */
        accept(observer: IObserver<T>): void;
        /**
         * Invokes the delegate corresponding to the notification or the observer's method corresponding to the notification and returns the produced result.
         *
         * @memberOf Notification
         * @param {Any} observerOrOnNext Delegate to invoke for an OnNext notification or Observer to invoke the notification on..
         * @param {Function} onError Delegate to invoke for an OnError notification.
         * @param {Function} onCompleted Delegate to invoke for an OnCompleted notification.
         * @returns {Any} Result produced by the observation.
         */
        accept<TResult>(onNext: (value: T) => TResult, onError: (exception: any) => TResult, onCompleted: () => TResult): TResult;

/**
         * Returns an observable sequence with a single notification.
         *
         * @memberOf Notifications
         * @param {Scheduler} [scheduler] Scheduler to send out the notification calls on.
         * @returns {Observable} The observable sequence that surfaces the behavior of the notification upon subscription.
         */
        toObservable(scheduler?: IScheduler): Observable<T>;

hasValue: boolean;
        equals(other: Notification<T>): boolean;
        kind: string;
        value: T;
        error: any;
    }

interface NotificationStatic {
        new <T>(kind: any, value: any, exception: any, accept: any, acceptObservable: any, toString: any) : Notification<T>;

/**
        * Creates an object that represents an OnNext notification to an observer.
        * @param {Any} value The value contained in the notification.
        * @returns {Notification} The OnNext notification containing the value.
        */
        createOnNext<T>(value: T): Notification<T>;
        /**
        * Creates an object that represents an OnError notification to an observer.
        * @param {Any} error The exception contained in the notification.
        * @returns {Notification} The OnError notification containing the exception.
        */
        createOnError<T>(exception: any): Notification<T>;
        /**
        * Creates an object that represents an OnCompleted notification to an observer.
        * @returns {Notification} The OnCompleted notification.
        */
        createOnCompleted<T>(): Notification<T>;
    }

export var Notification : NotificationStatic;
}

(function() {
    var notification: Rx.Notification<number> = new Rx.Notification<number>(undefined, undefined, undefined, undefined, undefined, undefined);

var observer: Rx.IObserver<number>;
    notification.accept(observer);
    notification.accept((n) => n.toString(), (e) => e, () => false.toString());

var observable: Rx.Observable<number> = notification.toObservable();
    var observable: Rx.Observable<number> = notification.toObservable(Rx.Scheduler.currentThread);

Rx.Notification.createOnNext(() => true);
    Rx.Notification.createOnError(new Error('a'));
    Rx.Notification.createOnCompleted();
});