Я думаю, что я, должно быть, неправильно понимаю что-то фундаментальное, потому что, на мой взгляд, это должно быть самым основным случаем для наблюдаемого, но для моей жизни я не могу понять, как это сделать из документов.

В принципе, я хочу быть в состоянии сделать это:

// create a dummy observable, which I would update manually
var eventObservable = rx.Observable.create(function(observer){});
var observer = eventObservable.subscribe(
   function(x){
     console.log('next: ' + x);
   }
...
var my_function = function(){
  eventObservable.push('foo'); 
  //'push' adds an event to the datastream, the observer gets it and prints 
  // next: foo
}

Но я не смог найти такой метод, какpush, Я использую это для обработчика кликов, и я знаю, что они имеютObservable.fromEvent для этого, но я пытаюсь использовать его с React, и я предпочел бы просто обновить поток данных в обратном вызове вместо использования совершенно другой системы обработки событий. В общем, я хочу это:

$( "#target" ).click(function(e) {
  eventObservable.push(e.target.text()); 
});

Самое близкое, которое я получил, использовалоobserver.onNext('foo')Но это, похоже, на самом деле не работает, и это вызывает наблюдателя, что кажется неправильным. Наблюдатель должен реагировать на поток данных, а не изменять его, верно?

Я просто не понимаю отношения наблюдатель / наблюдаемый?