SOURCE

var source$ = rxjs.of(1, 2);

var observer = {
    next: v => console.log('next>>>', v),
    error: e => console.log('error>>>', e),
    complete: () => console.log('complete'),
}

source$.subscribe(observer);