SOURCE

// const source = rxjs.of('1', '2');

// source.subscribe({
//     next: function(value) {
//         console.log(value);
//     },
//     complete: function() {
//         console.log('complete!');
//     },
//     error: function(error) {
//         console.log(error);
//     }
// });

// var arr = ['Jerry', 'Anna', 2016, 2017, '30 days'] 
// var source = rxjs.from(arr);

// source.subscribe({
//     next: function(value) {
//         console.log(value)
//     },
//     complete: function() {
//         console.log('complete!');
//     },
//     error: function(error) {
//         console.log(error)
//     }
// });

// var source = rxjs.from('铁人赛旧金山的就 水电费');

// source.subscribe({
//     next: function(value) {
//         console.log(value)
//     },
//     complete: function() {
//         console.log('complete!');
//     },
//     error: function(error) {
//         console.log(error)
//     }
// });

// var source = rxjs.from(new Promise((resolve, reject) => {
//     setTimeout(() => {
//       resolve('Hello RxJS!');
//     }, 3000)
//   }))

// source.subscribe({
//     next: function(value) {
//     	console.log(value)
//     },
//     complete: function() {
//     	console.log('complete!');
//     },
//     error: function(error) {
//     console.log(error)
//     }
// });


var source = rxjs.fromEvent(document.body, 'click');

source.subscribe({
    next: function(value) {
        console.log(value)
    },
    complete: function() {
        console.log('complete!');
    },
    error: function(error) {
        console.log(error)
    }
});