Rxjs

[RainZhai]

    /*     const source = Rx.Observable.fromPromise(new Promise(resolve => resolve(1)));
    //add 10 to the value
    const example = source.map(val => val + 10);
    //output: 11
    const subscribe = example.subscribe(val => console.log(val));*/
    const btn = document.getElementById("btn");
    const input = document.getElementById("inputbox");
    const btnstream = Rx.Observable.fromEvent(btn, "click");
    const inputstream = Rx.Observable.fromEvent(input, "keyup");
    btnstream.subscribe(e => console.log(e.target.value));
    inputstream.subscribe(e => console.log(e), err => console.log(err), () => console.log("完成"));

    /*        const source = Rx.Observable.range(0, 6).map(x => x * x);
    source.subscribe(val => console.log(val))*/

    /*        const source = Rx.Observable.from(["hel", "oo"]).map(x => x + "yoooo");
    source.subscribe(val => console.log(val))*/

    /*  const source = Rx.Observable(
    observer => {
    console.log("Observable create");
    observer.next("hello reactiveX");
    observer.next("another val");
    }
    )

    source.subscribe(x => console.log(x), err => console.log(err), complete => console.log(complete))
    */

    /*      const mypromise = new Promise((resolve, reject) => {
    console.log('create');
    setTimeout(() => {
    resolve("hi hghjgjg")
    }, 3000)
    })
    mypromise.then(x => {
    console.log("HHUUU");
    })
    const source = Rx.Observable.fromPromise(mypromise);
    source.subscribe(x => console.log(x))*/
    /*        const users = [{
    name: "hello",
    age: 11
    }, {
    name: "ggggo",
    age: 121
    }]
    const source = Rx.Observable.from(users).pluck('name');
    source.subscribe(x => console.log(x))

    Rx.Observable.interval(1000).take(3)
    .merge(Rx.Observable.interval(500).take(3))
    .subscribe(x => console.log(x))*/

    const clock = document.getElementById("clock");
    const clk = Rx.Observable.interval(1000).map(v => v + new Date().getTime());
    clk.subscribe(x => clock.innerHTML = x)