Ich denke, ich muss etwas Grundlegendes missverstehen, denn in meinen Augen sollte dies der grundlegendste Fall für ein Beobachtbares sein, aber für das Leben meines Ich kann nicht aus den Dokumenten herausfinden, wie es geht.

rundsätzlich möchte ich dazu in der Lage sein:

// 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
}

Aber ich konnte keine Methode wie @ findpush. Ich benutze dies für einen Klick-Handler und ich weiß, dass sie @ habObservable.fromEvent für das, aber ich versuche, es mit React zu verwenden, und ich wäre lieber in der Lage, den Datenstrom in einem Rückruf einfach zu aktualisieren, anstatt ein völlig anderes Ereignisbehandlungssystem zu verwenden. Also im Grunde will ich das:

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

Das nächste, was ich bekam, war mitobserver.onNext('foo'), aber das schien nicht wirklich zu funktionieren und das fordert den Beobachter auf, was nicht richtig zu sein scheint. Der Beobachter sollte das sein, was auf den Datenstrom reagiert und ihn nicht ändert, oder?

Verstehe ich die beobachter / beobachtbare Beziehung einfach nicht?