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
anonymoussubject.ts	733 B	-rw-rw-r--	2022-08-30 11:49
asyncsubject.ts	706 B	-rw-rw-r--	2022-08-30 11:49
behaviorsubject.ts	1.3 KB	-rw-rw-r--	2022-08-30 11:49
replaysubject.ts	1.29 KB	-rw-rw-r--	2022-08-30 11:49
subject.ts	1.94 KB	-rw-rw-r--	2022-08-30 11:49

Rename

/// <reference path="./subject.ts" />
/// <reference path="../concurrency/scheduler.ts" />
module Rx {
    export interface ReplaySubject<T> extends Subject<T> { }

interface ReplaySubjectStatic {
        /**
         *  Initializes a new instance of the ReplaySubject class with the specified buffer size, window size and scheduler.
         *  @param {Number} [bufferSize] Maximum element count of the replay buffer.
         *  @param {Number} [windowSize] Maximum time length of the replay buffer.
         *  @param {Scheduler} [scheduler] Scheduler the observers are invoked on.
         */
        new <T>(bufferSize?: number, window?: number, scheduler?: IScheduler): ReplaySubject<T>;
    }

/**
    * Represents an object that is both an observable sequence as well as an observer.
    * Each notification is broadcasted to all subscribed and future observers, subject to buffer trimming policies.
    */
    export var ReplaySubject: ReplaySubjectStatic;
}

(function() {
    var s : Rx.ReplaySubject<boolean> = new Rx.ReplaySubject<boolean>();
    var s : Rx.ReplaySubject<boolean> = new Rx.ReplaySubject<boolean>(10);
    var s : Rx.ReplaySubject<boolean> = new Rx.ReplaySubject<boolean>(10, 10);
    var s : Rx.ReplaySubject<boolean> = new Rx.ReplaySubject<boolean>(10, 10, Rx.Scheduler.async);
});