RxJs - 多个订阅者等待相同的承诺结果

Question

如果同一个承诺已经在进行中，而后来者已经给出了新的解决方案，我如何让多个订阅者等待解决？

doSomething = () => {
  return new Promise((resolve) => {
     setTimeout(() => resolve(Math.random(), 1000)
  })
}

// how to define obs?

obs.subscribe(v => console.log(v)); // 0.39458743297857473
obs.subscribe(v => console.log(v)); // 0.39458743297857473
obs.subscribe(v => console.log(v)); // 0.39458743297857473

setTimeout(() => obs.subscribe(v => console.log(v)), 2000); // 0.9485769395265746

我希望 observable 在第一个订阅者之前保持冷态，然后在结果流式传输到所有后续并发订阅者后再次冷态。我基本上不希望对同一个底层函数有任何并发​​请求。

Answer 1

您可以使用defer 作为创建操作符，然后使用share 流：

doSomething = () => {
  return new Promise((resolve) => {
     setTimeout(() => resolve(Math.random(), 1000));
  });
}

const obs = Rx.Observable
    .defer(doSomething)
    .share();

obs.subscribe(console.log); // resolve #1
obs.subscribe(console.log); // resolve #1
obs.subscribe(console.log); // resolve #1

setTimeout(() => obs.subscribe(console.log), 2000); // resolve #2

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>