如何使用Promise来返回这个未来价值

Question

我所拥有的简化版本：

const getAuthorizedConnection = () => {
let myAuthorizedConnection;
flowable.subscribe({
onComplete: connection => {
connection
.authorize(
authorizedConnection => {
myAuthorizedConection = authorizedConnection;
}
)
.subscribe(
messageFromConnection => {
processMessage(messageFromConnection);
}
);
}
});
return myAuthorizedConnection;
}

它显然写得不正确，但我不知道如何修复它。我认为正确的方法是使用Promise，以便在准备好时返回authorizedConnection，并将其保存到变量中，以便在其他地方重新使用它来访问授权的连接。但我不知道该怎么写。有人能帮忙吗？

Answer 1

你能给我们更多关于flawable的信息吗？如果flawable.subscribe是一个观察者，RxJS是一个可行的选项，我会考虑使用类似switchMap的东西来将flowable可观察到的(以及返回的连接(转换为来自.authorize的响应

https://rxjs-dev.firebaseapp.com/api/operators/switchMap