RxJS z niezmiennymi strukturami danych?

Question

pracuję przez RxJSKoans i widzę okresowy wzór karmienie w tablicy wyników, że abonent naciska na nowe wartości:

var Rx = require('rx'), 
    Subject = Rx.Subject 

var result = []; 
var s1 = new Subject(); 
s1.subscribe(result.push.bind(result)); 
s1.onNext('foo'); 
result; // ['foo'] 

To wyraźnie nieczyste funkcja; tablica result jest zmutowana przez subskrybowanie.

Widziałem small-scale projects on Github, które robią dźgnięcie przy użyciu Immutable.js, ale żaden nie jest aktywnie konserwowany.

Zastanawiam się, czy istnieje powszechnie przyjęty niezmienny wzór wdrożenia, a jeśli nie, dlaczego?

Answer 1

ja nie nazwałbym tego wzoru, ale ponieważ wszystko można przekazać za pomocą strumienia można również przejść w dowolnym niezmiennej struktury danych:

const stream$ = Rx.Subject.create(); 
 

 
stream$ 
 
    .map(data => data.set('a', data.get('a') + 1)) 
 
    .subscribe(data => console.log(data)); 
 

 
stream$.next(Immutable.Map({ a:1 })); 
 
stream$.next(Immutable.Map({ a:2 }));

<script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.7/dist/global/Rx.umd.js"></script> 
 
<script src="https://cdnjs.cloudflare.com/ajax/libs/immutable/3.8.1/immutable.js"></script>

Również Nie ma powodem, dla którego result jest stan zewnętrzny. Oto, jakie są metody takie jak scan. Jest to proponuję zrobić, aby zarządzać (wewnętrzne) Stan:

const stream$ = Rx.Subject.create(); 
 

 
stream$ 
 
    .scan((list, val) => list.push(val), Immutable.List()) 
 
    .subscribe(data => console.log(data)); 
 

 
stream$.next('foo'); 
 
stream$.next('bar');

<script src="https://npmcdn.com/@reactivex/rxjs@5.0.0-beta.7/dist/global/Rx.umd.js"></script> 
 
<script src="https://cdnjs.cloudflare.com/ajax/libs/immutable/3.8.1/immutable.js"></script>