Skip to content

Instantly share code, notes, and snippets.

@dan-cooke
Last active May 23, 2017 09:50
Show Gist options
  • Save dan-cooke/6cb68ed80478617ddc21e27f316d95bf to your computer and use it in GitHub Desktop.
Save dan-cooke/6cb68ed80478617ddc21e27f316d95bf to your computer and use it in GitHub Desktop.

Revisions

  1. dan-cooke revised this gist May 23, 2017. 3 changed files with 17 additions and 84 deletions.
    17 changes: 17 additions & 0 deletions Stream.js
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,17 @@
    "use strict";
    var Stream = (function () {
    function Stream(val) {
    this._source = new Rx.BehaviorSubject(val);
    this._obs = this._source.asObservable();
    return this._obs;
    }
    return Stream;
    }());

    Stream.prototype.next = function (val) {
    this._source.next(val);
    };

    var s = new Stream('test').subscribe(function (val) { return console.log(val); });

    s.next("next test");
    69 changes: 0 additions & 69 deletions index.html
    Original file line number Diff line number Diff line change
    @@ -1,69 +0,0 @@
    <!DOCTYPE html>
    <html>
    <head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width">
    <title>JS Bin</title>
    </head>
    <body>
    <script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/d3/4.2.3/d3.min.js"></script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/expect/1.20.2/expect.js"></script>
    <script id="jsbin-javascript">
    "use strict";
    var Stream = (function () {
    function Stream(val) {
    this._source = new Rx.BehaviorSubject(val);
    this._obs = this._source.asObservable();
    return this._obs;
    }
    Stream.prototype.next = function (val) {
    this._source.next(val);
    };
    return Stream;
    }());
    var s = new Stream('test').subscribe(function (val) { return console.log(val); });
    s.next("next test");
    //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoianNiaW4uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJqc2Jpbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUE7SUFJRSxnQkFBWSxHQUFHO1FBQ2IsSUFBSSxDQUFDLE9BQU8sR0FBRyxJQUFJLEVBQUUsQ0FBQyxlQUFlLENBQUMsR0FBRyxDQUFDLENBQUM7UUFDM0MsSUFBSSxDQUFDLElBQUksR0FBRyxJQUFJLENBQUMsT0FBTyxDQUFDLFlBQVksRUFBRSxDQUFDO1FBRXhDLE1BQU0sQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDO0lBQ25CLENBQUM7SUFFTSxxQkFBSSxHQUFYLFVBQVksR0FBUztRQUNuQixJQUFJLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxHQUFHLENBQUMsQ0FBQztJQUN6QixDQUFDO0lBQ0gsYUFBQztBQUFELENBQUMsQUFkRCxJQWNDO0FBRUQsSUFBSSxDQUFDLEdBQUcsSUFBSSxNQUFNLENBQUMsTUFBTSxDQUFDLENBQUMsU0FBUyxDQUFDLFVBQUEsR0FBRyxJQUFJLE9BQUEsT0FBTyxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsRUFBaEIsQ0FBZ0IsQ0FBQyxDQUFDO0FBRTlELENBQUMsQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJjbGFzcyBTdHJlYW0ge1xuICBcbiAgcHJpdmF0ZSBfc291cmNlIDogUnguU3ViamVjdDtcbiAgcHJpdmF0ZSBfb2JzIDogUnguT2JzZXJ2YWJsZTtcbiAgY29uc3RydWN0b3IodmFsKXtcbiAgICB0aGlzLl9zb3VyY2UgPSBuZXcgUnguQmVoYXZpb3JTdWJqZWN0KHZhbCk7XG4gICAgdGhpcy5fb2JzID0gdGhpcy5fc291cmNlLmFzT2JzZXJ2YWJsZSgpO1xuICAgIFxuICAgIHJldHVybiB0aGlzLl9vYnM7XG4gIH1cblxuICBwdWJsaWMgbmV4dCh2YWwgOiBhbnkpe1xuICAgIHRoaXMuX3NvdXJjZS5uZXh0KHZhbCk7XG4gIH1cbn1cblxubGV0IHMgPSBuZXcgU3RyZWFtKCd0ZXN0Jykuc3Vic2NyaWJlKHZhbCA9PiBjb25zb2xlLmxvZyh2YWwpKTtcblxucy5uZXh0KFwibmV4dCB0ZXN0XCIpOyJdfQ==
    </script>

    <script id="jsbin-source-html" type="text/html">
    <!DOCTYPE html>
    <html>
    <head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width">
    <title>JS Bin</title>
    </head>
    <body>
    <script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"><\/script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/d3/4.2.3/d3.min.js"><\/script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/expect/1.20.2/expect.js"><\/script>
    </body>
    </html></script>


    <script id="jsbin-source-javascript" type="text/javascript">class Stream {

    private _source : Rx.Subject;
    private _obs : Rx.Observable;
    constructor(val){
    this._source = new Rx.BehaviorSubject(val);
    this._obs = this._source.asObservable();

    return this._obs;
    }

    public next(val : any){
    this._source.next(val);
    }
    }

    let s = new Stream('test').subscribe(val => console.log(val));

    s.next("next test");



    </script></body>
    </html>
    15 changes: 0 additions & 15 deletions jsbin.todewiz.js
    Original file line number Diff line number Diff line change
    @@ -1,15 +0,0 @@
    "use strict";
    var Stream = (function () {
    function Stream(val) {
    this._source = new Rx.BehaviorSubject(val);
    this._obs = this._source.asObservable();
    return this._obs;
    }
    Stream.prototype.next = function (val) {
    this._source.next(val);
    };
    return Stream;
    }());
    var s = new Stream('test').subscribe(function (val) { return console.log(val); });
    s.next("next test");
    //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoianNiaW4uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJqc2Jpbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUE7SUFJRSxnQkFBWSxHQUFHO1FBQ2IsSUFBSSxDQUFDLE9BQU8sR0FBRyxJQUFJLEVBQUUsQ0FBQyxlQUFlLENBQUMsR0FBRyxDQUFDLENBQUM7UUFDM0MsSUFBSSxDQUFDLElBQUksR0FBRyxJQUFJLENBQUMsT0FBTyxDQUFDLFlBQVksRUFBRSxDQUFDO1FBRXhDLE1BQU0sQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDO0lBQ25CLENBQUM7SUFFTSxxQkFBSSxHQUFYLFVBQVksR0FBUztRQUNuQixJQUFJLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxHQUFHLENBQUMsQ0FBQztJQUN6QixDQUFDO0lBQ0gsYUFBQztBQUFELENBQUMsQUFkRCxJQWNDO0FBRUQsSUFBSSxDQUFDLEdBQUcsSUFBSSxNQUFNLENBQUMsTUFBTSxDQUFDLENBQUMsU0FBUyxDQUFDLFVBQUEsR0FBRyxJQUFJLE9BQUEsT0FBTyxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsRUFBaEIsQ0FBZ0IsQ0FBQyxDQUFDO0FBRTlELENBQUMsQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJjbGFzcyBTdHJlYW0ge1xuICBcbiAgcHJpdmF0ZSBfc291cmNlIDogUnguU3ViamVjdDtcbiAgcHJpdmF0ZSBfb2JzIDogUnguT2JzZXJ2YWJsZTtcbiAgY29uc3RydWN0b3IodmFsKXtcbiAgICB0aGlzLl9zb3VyY2UgPSBuZXcgUnguQmVoYXZpb3JTdWJqZWN0KHZhbCk7XG4gICAgdGhpcy5fb2JzID0gdGhpcy5fc291cmNlLmFzT2JzZXJ2YWJsZSgpO1xuICAgIFxuICAgIHJldHVybiB0aGlzLl9vYnM7XG4gIH1cblxuICBwdWJsaWMgbmV4dCh2YWwgOiBhbnkpe1xuICAgIHRoaXMuX3NvdXJjZS5uZXh0KHZhbCk7XG4gIH1cbn1cblxubGV0IHMgPSBuZXcgU3RyZWFtKCd0ZXN0Jykuc3Vic2NyaWJlKHZhbCA9PiBjb25zb2xlLmxvZyh2YWwpKTtcblxucy5uZXh0KFwibmV4dCB0ZXN0XCIpOyJdfQ==
  2. dan-cooke created this gist May 23, 2017.
    69 changes: 69 additions & 0 deletions index.html
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,69 @@
    <!DOCTYPE html>
    <html>
    <head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width">
    <title>JS Bin</title>
    </head>
    <body>
    <script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"></script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/d3/4.2.3/d3.min.js"></script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/expect/1.20.2/expect.js"></script>
    <script id="jsbin-javascript">
    "use strict";
    var Stream = (function () {
    function Stream(val) {
    this._source = new Rx.BehaviorSubject(val);
    this._obs = this._source.asObservable();
    return this._obs;
    }
    Stream.prototype.next = function (val) {
    this._source.next(val);
    };
    return Stream;
    }());
    var s = new Stream('test').subscribe(function (val) { return console.log(val); });
    s.next("next test");
    //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoianNiaW4uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJqc2Jpbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUE7SUFJRSxnQkFBWSxHQUFHO1FBQ2IsSUFBSSxDQUFDLE9BQU8sR0FBRyxJQUFJLEVBQUUsQ0FBQyxlQUFlLENBQUMsR0FBRyxDQUFDLENBQUM7UUFDM0MsSUFBSSxDQUFDLElBQUksR0FBRyxJQUFJLENBQUMsT0FBTyxDQUFDLFlBQVksRUFBRSxDQUFDO1FBRXhDLE1BQU0sQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDO0lBQ25CLENBQUM7SUFFTSxxQkFBSSxHQUFYLFVBQVksR0FBUztRQUNuQixJQUFJLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxHQUFHLENBQUMsQ0FBQztJQUN6QixDQUFDO0lBQ0gsYUFBQztBQUFELENBQUMsQUFkRCxJQWNDO0FBRUQsSUFBSSxDQUFDLEdBQUcsSUFBSSxNQUFNLENBQUMsTUFBTSxDQUFDLENBQUMsU0FBUyxDQUFDLFVBQUEsR0FBRyxJQUFJLE9BQUEsT0FBTyxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsRUFBaEIsQ0FBZ0IsQ0FBQyxDQUFDO0FBRTlELENBQUMsQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJjbGFzcyBTdHJlYW0ge1xuICBcbiAgcHJpdmF0ZSBfc291cmNlIDogUnguU3ViamVjdDtcbiAgcHJpdmF0ZSBfb2JzIDogUnguT2JzZXJ2YWJsZTtcbiAgY29uc3RydWN0b3IodmFsKXtcbiAgICB0aGlzLl9zb3VyY2UgPSBuZXcgUnguQmVoYXZpb3JTdWJqZWN0KHZhbCk7XG4gICAgdGhpcy5fb2JzID0gdGhpcy5fc291cmNlLmFzT2JzZXJ2YWJsZSgpO1xuICAgIFxuICAgIHJldHVybiB0aGlzLl9vYnM7XG4gIH1cblxuICBwdWJsaWMgbmV4dCh2YWwgOiBhbnkpe1xuICAgIHRoaXMuX3NvdXJjZS5uZXh0KHZhbCk7XG4gIH1cbn1cblxubGV0IHMgPSBuZXcgU3RyZWFtKCd0ZXN0Jykuc3Vic2NyaWJlKHZhbCA9PiBjb25zb2xlLmxvZyh2YWwpKTtcblxucy5uZXh0KFwibmV4dCB0ZXN0XCIpOyJdfQ==
    </script>

    <script id="jsbin-source-html" type="text/html">
    <!DOCTYPE html>
    <html>
    <head>
    <meta charset="utf-8">
    <meta name="viewport" content="width=device-width">
    <title>JS Bin</title>
    </head>
    <body>
    <script src="https://unpkg.com/@reactivex/[email protected]/dist/global/Rx.js"><\/script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/d3/4.2.3/d3.min.js"><\/script>
    <script src="https://cdnjs.cloudflare.com/ajax/libs/expect/1.20.2/expect.js"><\/script>
    </body>
    </html></script>


    <script id="jsbin-source-javascript" type="text/javascript">class Stream {

    private _source : Rx.Subject;
    private _obs : Rx.Observable;
    constructor(val){
    this._source = new Rx.BehaviorSubject(val);
    this._obs = this._source.asObservable();

    return this._obs;
    }

    public next(val : any){
    this._source.next(val);
    }
    }

    let s = new Stream('test').subscribe(val => console.log(val));

    s.next("next test");



    </script></body>
    </html>
    15 changes: 15 additions & 0 deletions jsbin.todewiz.js
    Original file line number Diff line number Diff line change
    @@ -0,0 +1,15 @@
    "use strict";
    var Stream = (function () {
    function Stream(val) {
    this._source = new Rx.BehaviorSubject(val);
    this._obs = this._source.asObservable();
    return this._obs;
    }
    Stream.prototype.next = function (val) {
    this._source.next(val);
    };
    return Stream;
    }());
    var s = new Stream('test').subscribe(function (val) { return console.log(val); });
    s.next("next test");
    //# sourceMappingURL=data:application/json;base64,eyJ2ZXJzaW9uIjozLCJmaWxlIjoianNiaW4uanMiLCJzb3VyY2VSb290IjoiIiwic291cmNlcyI6WyJqc2Jpbi50cyJdLCJuYW1lcyI6W10sIm1hcHBpbmdzIjoiO0FBQUE7SUFJRSxnQkFBWSxHQUFHO1FBQ2IsSUFBSSxDQUFDLE9BQU8sR0FBRyxJQUFJLEVBQUUsQ0FBQyxlQUFlLENBQUMsR0FBRyxDQUFDLENBQUM7UUFDM0MsSUFBSSxDQUFDLElBQUksR0FBRyxJQUFJLENBQUMsT0FBTyxDQUFDLFlBQVksRUFBRSxDQUFDO1FBRXhDLE1BQU0sQ0FBQyxJQUFJLENBQUMsSUFBSSxDQUFDO0lBQ25CLENBQUM7SUFFTSxxQkFBSSxHQUFYLFVBQVksR0FBUztRQUNuQixJQUFJLENBQUMsT0FBTyxDQUFDLElBQUksQ0FBQyxHQUFHLENBQUMsQ0FBQztJQUN6QixDQUFDO0lBQ0gsYUFBQztBQUFELENBQUMsQUFkRCxJQWNDO0FBRUQsSUFBSSxDQUFDLEdBQUcsSUFBSSxNQUFNLENBQUMsTUFBTSxDQUFDLENBQUMsU0FBUyxDQUFDLFVBQUEsR0FBRyxJQUFJLE9BQUEsT0FBTyxDQUFDLEdBQUcsQ0FBQyxHQUFHLENBQUMsRUFBaEIsQ0FBZ0IsQ0FBQyxDQUFDO0FBRTlELENBQUMsQ0FBQyxJQUFJLENBQUMsV0FBVyxDQUFDLENBQUMiLCJzb3VyY2VzQ29udGVudCI6WyJjbGFzcyBTdHJlYW0ge1xuICBcbiAgcHJpdmF0ZSBfc291cmNlIDogUnguU3ViamVjdDtcbiAgcHJpdmF0ZSBfb2JzIDogUnguT2JzZXJ2YWJsZTtcbiAgY29uc3RydWN0b3IodmFsKXtcbiAgICB0aGlzLl9zb3VyY2UgPSBuZXcgUnguQmVoYXZpb3JTdWJqZWN0KHZhbCk7XG4gICAgdGhpcy5fb2JzID0gdGhpcy5fc291cmNlLmFzT2JzZXJ2YWJsZSgpO1xuICAgIFxuICAgIHJldHVybiB0aGlzLl9vYnM7XG4gIH1cblxuICBwdWJsaWMgbmV4dCh2YWwgOiBhbnkpe1xuICAgIHRoaXMuX3NvdXJjZS5uZXh0KHZhbCk7XG4gIH1cbn1cblxubGV0IHMgPSBuZXcgU3RyZWFtKCd0ZXN0Jykuc3Vic2NyaWJlKHZhbCA9PiBjb25zb2xlLmxvZyh2YWwpKTtcblxucy5uZXh0KFwibmV4dCB0ZXN0XCIpOyJdfQ==