È possibile osservare aggiunte a un array con rx.js?

Question

fromArray Rx wiki on github

coffee> rext = require 'rx'             
coffee> arr = [1..5]             
[ 1, 2, 3, 4, 5 ]              
coffee> obs = rext.Observable.fromArray(arr)       
{ _subscribe: [Function] }           
coffee> obs.subscribe((x) -> console.log("added value: " + x))  
added value: 1              
added value: 2              
added value: 3              
added value: 4              
added value: 5              
{ isStopped: true,             
    observer:               
    { isStopped: true,             
    _onNext: [Function],            
    _onError: [Function: defaultError],        
    _onCompleted: [Function: noop] },        
    m: { isDisposed: true, current: null } }       
coffee> arr.push(12) # expecting "added value: 12"            
6      # instead got new length of array            
coffee>   

Sembra veramente la funzione subscribe sarà sparare solo una volta, quando è creato. Sembra che sia un po 'un termine improprio, dal momento che io sono solo per la matrice, invece di osservare i cambiamenti su di essa. Questo codice è quasi identico a quello che si trova sul wiki. Quindi o sto sbagliando o il subscribe non funziona come mi aspetto.

Answer 1

Observable.fromArray crea un Observable che attiva immediatamente gli eventi per ogni elemento dell'array quando si aggiunge un Sottoscrittore. Quindi, non "guarderà" le modifiche a quell'array.

Se hai bisogno di una "raccolta pushable", la classe Bus in Bacon.js potrebbe essere quello che stai cercando. Per RxJs c'è la mia piccola classe MessageQueue che ha una funzionalità simile.

Answer 2

Ho trovato Rx.Observable.ofObjectChanges(obj) funzionare come mi aspettavo.

Dalla pagina di documentazione:

Crea una sequenza osservabile da modifiche a un oggetto utilizzando Object.observe.

Spero che sia d'aiuto.

Answer 3

In RxJS quello che stai cercando si chiama Subject. Puoi spingere i dati in esso e trasmetterli da lì.

• Subject getting started guide
• Subject API docs.

Esempio:

var array = []; 
var arraySubject = new Rx.Subject(); 

var pushToArray = function (item) { 
    array.push(item); 
    arraySubject.next(item); 
} 

// Subscribe to the subject to react to changes 
arraySubject.subscribe((item) => console.log(item));