Gecko [ unitednationsplay.com ]

Linux unitednationsplay.com 3.10.0-1160.45.1.el7.x86_64 #1 SMP Wed Oct 13 17:20:51 UTC 2021 x86_64
nginx/1.20.1
Server IP : 188.130.139.92 & Your IP : 216.73.216.44
Domains : Cant Read [ /etc/named.conf ]
User : web

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="./observer-lite.ts" />
module Rx {
    export module internals {
        /**
        * Abstract base class for implementations of the Observer class.
        * This base class enforces the grammar of observers where OnError and OnCompleted are terminal messages.
        */
        export interface AbstractObserver<T> extends Rx.IObserver<T>, Rx.IDisposable {
            /**
            * 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;

isStopped: boolean;

/**
            * Disposes the observer, causing it to transition to the stopped state.
            */
            dispose(): void;

fail(e: any): boolean;

// Must be implemented by other observers
            next(value: T): void;
            error(error: any): void;
            completed(): void;
        }

interface AbstractObserverStatic {
            new <T>(): AbstractObserver<T>;
        }

export var AbstractObserver: AbstractObserverStatic
    }
}

(function() {
    var iObserver: Rx.IObserver<number>;
    var abstractObserver: Rx.internals.AbstractObserver<number>;

iObserver = abstractObserver;
});