RxJS로 함수/연산자 작성

Question

점 표기법없이 RxJS로 함수를 작성하는 방법이 있습니까?

사용 사례 : 이벤트의 내 ​​스트림은 구성 가능한 기능으로 처리 될 수 있으며 배열에 추가하여 구성하려고합니다. 다음과 같이

const result$ = source$.map(function1).map(function2).map(function3) 

나는 farray = [function1, function2, function3]이 그것을 사용하고 싶습니다 :

const result$ = source$.compose(farray) 

이유가 실행 중 (또는 초기화시)를 farray을 변경 할 수 있어야한다는 것입니다.

나는 map 및 filter과 기타 Rx 버전과 어떻게 반응하는지 알 수는 없지만 을 찾았습니다.

팁 주셔서 감사합니다.

Answer 1

지도와 함께 Rambda.compose를 사용할 수 있습니다.

const functions = [x => x * 2, x => x + 1] 
 

 
Rx.Observable 
 
    .range(0, 10) 
 
    .map(R.compose(...functions)) 
 
    .subscribe(console.log);

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.1.0/rx.all.js"></script> 
 
<script src="//cdnjs.cloudflare.com/ajax/libs/ramda/0.21.0/ramda.min.js"></script>

또는 당신은 당신의 자신의 연산자를 만들 수 있습니다

const functions = [x => x * 2, x => x + 1]; 
 

 
Rx.Observable.prototype.mapCompose = function (functions) { 
 
    return this.map(R.compose(...functions)); 
 
}; 
 

 
Rx.Observable 
 
    .range(0, 10) 
 
    .mapCompose(functions) 
 
    .subscribe(console.log);

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.1.0/rx.all.js"></script> 
 
<script src="//cdnjs.cloudflare.com/ajax/libs/ramda/0.21.0/ramda.min.js"></script>

년 OFC, Rambda이 구성은 다른 작성 구현을 위해 전환 할 수 있습니다.

편집 : Rx 연산자 작성은 좀 더 복잡합니다. 그것을 구현하는 것은 말할 것도없고 그것이 어떻게 생겼는지 상상하기 어렵습니다. 그러나 관찰 할 수 있고 관찰 가능한 일부 함수를 항상 작성 (또는 적용) 할 수 있습니다. 다음은 구현 예입니다.

Rx.Observable.prototype.apply = function (functions) { 
 
    functions = [].concat(functions); 
 
    
 
    return functions.reduce(function (observable, func) { 
 
    return func(observable); 
 
    }, this); 
 
}; 
 

 
var functions = [obs => obs.map(x => x*2), obs => obs.filter(x => x % 3 === 0)]; 
 

 
Rx.Observable 
 
    .range(0, 15) 
 
    .apply(functions) 
 
    .subscribe(console.log);

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/4.1.0/rx.all.js"></script>