Создание вручную наблюдаемых

Question

Я использую для разработки моего интерфейса OpenUI5 и не поддерживает rxjs.

Например, я хочу слушать пресс кнопку от OpenUI5 события и не могли бы сделать, как

var source = Rx.Observable.fromEvent(input, 'press'); 

var subscription = source.subscribe(
    function (x) { 
    console.log('Next: Clicked!'); 
    }, 
    function (err) { 
    console.log('Error: %s', err); 
    }, 
    function() { 
    console.log('Completed'); 
    }); 

Поскольку элемент управления Button не реализует слушателя событий.

Так что я должен создать Observable самостоятельно, как создать горячую Наблюдаемую?

Answer 1

Если fromEvent не работает для вас, или, например, вы хотите подключить несколько событий к одному потоку вы можете сделать что-то вроде этого:

function mouseAllTheThingsStream(){ 
    const target = document.getElementById('#content'); 
    return Rx.Observable.create(observer => { 
    target.onmousemove(evt => observer.onNext(evt)); 
    target.onmousedown(evt => observer.onNext(evt)); 

    window.setTimeout(() => observer.onCompleted(), 30 * 1000); 

    return() => { 
     // cleanup; unsubscribe from events manually 
    } 
    }); 
}