const { fromEvent } = rxjs;

const goButton = document.querySelector('#goButton');


const observer = {
    next: res => {
        console.log(res);
    },
    error: err => {
        console.log(err);
    },
    complete: res => {
        console.log('kész')
    }
}

const observable = fromEvent(goButton, 'click');
observable.subscribe(observer);