执行 promise 后完成 observable

Question

我必须同时使用promise和observable。

我的前端使用 Angular，在我的代码中，我必须使用另一个 JavaScript 库。

我必须使用这个返回承诺的 JavaScript 库创建许多请求。

let pki = new Library();
let signed: Array<string> = []

const AssinaObservable = new Observable((observers) => {
  observers.next(
    tokens.forEach( (value,index) => {
      pki.sign({thumbprint:thumbprint, token: value})
      .success(result => {
        signed.push(result);
      })
    })
  )
});

observers.complete()
return MyObservable;

我希望仅在执行 foreach 中的所有请求后才能完成我的 observable。

我已经尝试了很多事情，但在执行我的所有请求之前我找不到它完成的原因。

pki.sign 返回一个承诺。 await 不适用于此功能。

Answer 1

您可以使用 rxJs 运算符 forkJoin 在执行多个 Promise 后完成一个 observable。只需将一组 Promises 传递给它，它就会调用 next 并在所有 Promise 完成后完成。你应该在 observable 的订阅中处理 promise 数据。

let pki = new Library();
let signed: Array<string> = []

const promises = tokens.map( (value, index) => {
    return pki.sign({thumbprint:thumbprint, token: value});
});

forkJoin(promises)
    .subscribe({
        next: (data) => signed.push(result) // handle next ,
        complete: () => // complete called,
    });

Answer 2

您可以使用 RxJS from 函数将 promise 转换为 observable。相应地，也可以使用 Array#map 和 RxJS forkJoin 来并行触发多个 observables。它会返回一个响应数组。

试试下面的

import { Observable, from } from 'rxjs';
import { forkJoin } from 'rxjs/operators';

public someFunction(): Observable<any> {
  return forkJoin(
    tokens.map(value => 
      from(pki.sign({thumbprint: thumbprint, token: value}).success())
    )
  );
}