Czy mogę obserwować dodatki do tablicy za pomocą 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>   

To naprawdę wygląda funkcji subscribe będzie tylko jeden raz ognia, kiedy to stworzył. Wygląda na to, że jest to trochę mylące, ponieważ jestem po prostu za tym, że szykuję tablicę zamiast obserwować zmiany na niej. Ten kod jest prawie identyczny z tym, który znajduje się na wiki. Więc albo robię to źle, albo subscribe nie działa tak, jak się spodziewam.

Answer 1

Observable.fromArray tworzy obserwowalne, które natychmiast uruchamia zdarzenia dla każdego elementu tablicy, po dodaniu subskrybenta. Tak więc nie będzie to "obserwowanie" zmian w tej tablicy.

Jeśli potrzebujesz "kolekcji do przesuwania", klasa Bus w Bacon.js może być tym, czego szukasz. Dla RxJs jest moja mała klasa MessageQueue, która ma podobną funkcjonalność.

Answer 2

Znalazłem Rx.Observable.ofObjectChanges(obj) do pracy tak, jak się spodziewałem.

Od strony dokumentacji:

Tworzy obserwowalnych sekwencję zmian do obiektu z wykorzystaniem Object.observe.

Mam nadzieję, że to pomaga.

Answer 3

W RxJS to, czego szukasz, nazywa się Subject. Możesz przesyłać do niego dane i przesyłać je strumieniowo.

• Subject getting started guide
• Subject API docs.

Przykład:

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));