Rxjs - Operators - StartWith

startWith可以作为一种默认初始值的用法

当然因为可以在流前面插入多个值,所以这个operator比单纯初始值更强大

var source = Rx.Observable.return(4)
    .startWith(1, 2, 3)

var subscription = source.subscribe(
    function (x) {
        console.log('Next: ' + x);
    },
    function (err) {
        console.log('Error: ' + err);
    },
    function () {
        console.log('Completed');
    });

setTimeout(function () {
    var subscription2 = source.subscribe(
        function (x) {
            console.log('Next2: ' + x);
        },
        function (err) {
            console.log('Error2: ' + err);
        },
        function () {
            console.log('Completed2');
        });
}, 2000)

Scheduler还没研究,所以没有写