如何从回调中返回可观察的

Question

我有一项服务，要实现SDK的逻辑。 从这个SDK我想调用一个返回有效载荷的事件。
我想创建一种调用事件的方法，并将其包裹在可观察的情况下，以订阅事件的响应。 我还创建了一个接口，以确保SDK响应的类型安全。

这就是到目前为止创建的内容：

export interface SdkPayload{
     avatar,
     name,
     jobTitle,
     availability
    }

export class TestService {
    sdk:someSDK;
    

     //method that returns an Observable
    getPayload$(): Observable<SdkPayload[]> {

//创建接口中定义的类型的新观察。 返回新的观察值＆lt; sdkpayload []＆gt;（（（subscriber）=＆gt; { const callbackFunction = （sdkpayload：sdkpayload []）=＆gt; {

                    this.someSDK.on('connected', (payload) => {
                      
                        payload.greeting.agent.avatar,
                        payload.greeting.agent.name,
                        payload.greeting.agent.jobTitle,
                        payload.availability;
                    });
                    
                    subscriber.next(sdkPayload);
                };
                this.customerSDK.on('connected', callbackFunction);
                return () => {
                    this.customerSDK('off', callbackFunction);
                };
            });
        }

组件：

    export class AppComponent{
       payloadResults$: Observable<SdkPayload[]>;
    
    constructor (private service:TestService){}
    
    callMethod(){
     this.payloadResults$=this.service.getPayload$();
    }
}

我感觉到我从SDK中使用的事件未正确实现或正确地包装在可观察到的情况下。最后，我的目标是将SDK响应包装成可观察的响应，以便我可以订阅其响应。

Answer 1

您可以创建一个主题。
在服务类中，主题：

  sdkPayloadSubject = new Subject<SdkPayload[]>();
 // transfor subject to an observable
    payloadResults$: Observable<SdkPayload[]> = this.sdkPayloadSubject.asObservable();
//add method accept each triggered sdk value
newLoadedSdkValue(newSdkPayload:SdkPayload[]){
this.sdkPayloadSubject.next(newSdkPayload);
}

在您的getPayload函数上，您可以使用上面的函数触发新值，而不是可观察到：

subscriber.next(sdkPayload);

使用您可以使用新的可观察格式

this.newLoadedSdkValue(sdkPayload);

然后在组件类上

    constructor (private service:TestService){
this.payloadResults$ = this.service.payloadResults$

}