RxJS Merge Callback에서 관찰 가능

Question

함수를 만들면 관찰 할 수있는 결과를 얻는 데 약간의 도움이 필요합니다. 함수 (전화가 mainFunction), 비동기 함수 (호출하자 getAsyncWithCallback) 호출하고 콜백을 실행합니다. 콜백의 일부는 관찰 가능 객체를 반환하는 비동기 호출입니다 (getData이라고 부름).

getAsyncWithCallback은 (는) 라이브러리의 일부이며 변경할 수 없습니다. 이것은 내가하고 싶은 것입니다

mainFunction(){ 
    getAsyncWithCallback(() => { 
     let myObservable = getData(); 
    }); 
} 

:

이

mainFunction().subscribe((data) => { 
    // data is the data from getData() 
}); 

이를 달성하는 가장 좋은 방법은 무엇입니까, 체인 오류 및 준공을 형성

이

내가 가진 무엇 안의?

Answer 1

내 솔루션 :

mainFunction(): Observable<any> { 

    return Rx.Observable.create(observer => { 
     getAsyncWithCallback((): void => { 
      getData().subscribe(observer); 
     }) 
    }) 
} 

mainFunction().subscribe((data) => { 
    console.log(data); 
})); 

Answer 2

당신은 mainFunction에서 관찰 가능한을 반환 할 것입니다. GetData의는 관찰 가능한 아닌 객체의 다른 유형을 반환하는 경우

, 당신은 Observable.create 함께 자신의 관찰 가능한을 구성합니다 :

function mainFunction() { 
    return Observable.create((obs) => { 
    getAsyncWithCallback(() => { 
     getData() 
     .subscribe((data) => { obs.next(data); }) 
     .catch((err) => { obs.error(err) }); 
    }); 
    }); 
} 

mainFunction().subscribe(data => console.log(data)); 

를 문서에서 :

생성

가에 onSubscription 기능을 변환 실제 Observable. 누군가가 Observable을 구독 할 때마다 함수는 Observer 인스턴스를 첫 번째이자 유일한 매개 변수로 호출합니다.

다음 값을 호출하면 해당 값이 관찰자에게 방출됩니다.

대부분의 경우 기존 연산자를 사용하면 대부분의 사용 사례에 대해 관찰 가능을 만들 수 있기 때문에 create를 사용하지 않아도됩니다. 즉, 매우 구체적인 요구 사항이있는 경우 create는 낮은 수준의 메커니즘으로 Observable을 만들 수 있습니다.

배열, 배열 모양의 개체, 반복기, 관찰 가능한 개체 및 약속에서 Observables를 만드는 Observable.from도 있습니다.