RXJS를 사용하여 함수 호출을 스트리밍 아웃

Question

내 문제는 간단하지만 RXJS의 다른 튜토리얼에 따라 답변을 찾을 수 없습니다. 서버 호출을하는 함수가있는 저장소가 있습니다.이 함수는 시작시에 구성 요소에서 바로 호출되며 이후에는 업데이트가 필요합니다. fromEvent는 HTML 요소에서 keyBoard 또는 Mouse Event를 관찰하는 데 사용되므로 해당 함수를 Observable로 지정하려고합니다.

어떻게 그 함수를 각 호출에서 약속을 반환하는 스트림으로 바꿀 수 있습니까?

this.getData(args) <Promise> 

사실, 내 스토어에서 해당 스트림을 구독하고 각 getData 호출에서 응용 프로그램 상태를 업데이트해야합니다.

this.getData.flatMap(promise => promise) 
.subscribe(result => this.state.data = result) 

Answer 1

좋아, 난 당신이 특정 함수에 대한 호출을 관찰 Rx.observable 주위를 포장 할 때마다이 RXJS

어떤 바보 초보자에게 유용 할 수 있습니다, 무엇을 찾고 있었다 발견했다.

Rx.Observable.create(obs=>{ 
    this.getRestaurant = (variableString, variables, fragments) => { 
     const query = this.getQuery(variableString, fragments) 
     obs.onNext(graphQLFetcher({query: query, variables: variables})) 
    } 
    }) 
    .flatMap(promise => Rx.Observable.fromPromise(promise)) 
    .subscribe(result => { 
    console.log(result) 
    }); 

지금 당신이 this.getRestaurant (인수) 호출을 기반으로 좋은 흐름을 다음과 같이 만듭니다.