// 宣告一個觀察者，具備 next, error, complete 三個方法

var observer = {

    next: function(value) {

        console.log(value);

    },

    error: function(error) {

        console.log(error)

    },

    complete: function() {

        console.log('complete')

    }

}

​

var observable = Rx.Observable

    .create(function(observer) {

            observer.next('Jerry');

            observer.next('Anna');

            observer.complete();

            observer.next('not work');

    })

// 用我們定義好的觀察者，來訂閱這個 observable  

observable.subscribe(observer)