Я попытался изучить внутреннюю реализацию наблюдаемых. Этот поток кода, согласно моему пониманию, движется в правильном направлении?
function OBSERVABLE(callback){
this.subscribe=callback.bind(this);
};
var obs$=new OBSERVABLE(function(observer){
this.next=observer.next;
});
obs$.subscribe({next:function(e){
console.log(e);
});