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>   

은 정말에만 불 한 번,이 만들어지는 것이다 subscribe 기능처럼 보인다. 내가 진짜로 단지 변화를 관찰하는 대신에 배열을 각각 사용하기 때문에 그것은 다소 잘못된 이름 인 것 같다. 이 코드는 위키에있는 코드와 거의 동일합니다. 그래서 내가 잘못했거나 subscribe이 내가 예상 한대로 작동하지 않습니다.

Answer 1

Observable.fromArray는 구독자를 추가 할 때 각 배열 항목에 대한 이벤트를 즉시 발생시키는 Observable을 만듭니다. 그래서, 그것은 그 배열에 대한 변화를 "지켜 보지"않을 것입니다.

"밀어 넣기 가능한 모음"이 필요한 경우 Bacon.js의 Bus 클래스가 원하는 것일 수 있습니다. RxJ의 경우 유사한 기능을 가진 작은 MessageQueue 클래스가 있습니다.

Answer 2

내가 예상했던대로 Rx.Observable.ofObjectChanges(obj)이 작동합니다. 문서 페이지에서

:

는 Object.observe를 사용하여 객체에 대한 변경에서 관찰 가능한 순서를 작성합니다.

희망이 있습니다.

Answer 3

RxJS에서 찾고있는 것은 Subject입니다. 데이터를 데이터로 푸시하고 거기에서 스트리밍 할 수 있습니다.

Subject getting started guide

Subject API docs

• .

예 :

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