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="./checkedobserver.ts" />
module Rx {
    /**
    * Supports push-style iteration over an observable sequence.
    */
    export interface IObserver<T> {
        /**
        * Notifies the observer of a new element in the sequence.
        * @param {Any} value Next element in the sequence.
        */
        onNext(value: T): void;
        /**
        * Notifies the observer that an exception has occurred.
        * @param {Any} error The error that has occurred.
        */
        onError(exception: any): void;
        /**
        * Notifies the observer of the end of the sequence.
        */
        onCompleted(): void;
    }
    
    export interface Observer<T> {
        /**
        * Notifies the observer of a new element in the sequence.
        * @param {Any} value Next element in the sequence.
        */
        onNext(value: T): void;
        /**
        * Notifies the observer that an exception has occurred.
        * @param {Any} error The error that has occurred.
        */
        onError(exception: any): void;
        /**
        * Notifies the observer of the end of the sequence.
        */
        onCompleted(): void;
    }

export interface ObserverStatic {
        /**
        *  Creates an observer from the specified OnNext, along with optional OnError, and OnCompleted actions.
        * @param {Function} [onNext] Observer's OnNext action implementation.
        * @param {Function} [onError] Observer's OnError action implementation.
        * @param {Function} [onCompleted] Observer's OnCompleted action implementation.
        * @returns {Observer} The observer object implemented using the given actions.
        */
        create<T>(onNext?: (value: T) => void, onError?: (exception: any) => void, onCompleted?: () => void): Observer<T>;
    }

/**
    * Supports push-style iteration over an observable sequence.
    */
    export var Observer: ObserverStatic;
}

(function() {
    var iobserver: Rx.IObserver<boolean>;
    var observer: Rx.Observer<boolean>;

iobserver.onNext(false);
    iobserver.onError(new Error('a'));
    iobserver.onCompleted();

observer.onNext(false);
    observer.onError(new Error('a'));
    observer.onCompleted();

var so: Rx.Observer<number> = Rx.Observer.create((v) => 1);
    so = Rx.Observer.create((v) => 1, (e) => { });
    so = Rx.Observer.create((v) => 1, (e) => { }, () => { });
});