SOURCE

const Observable = rxjs.Observable;
const Subject = rxjs.Subject;
Subject.subscribe({next:function(value){
    console.log(value)
}})
Subject.next('run command')