Async Task Queue for RxJS

Checkout: Code Sandbox Example

You can simply create an instance to get a new Subject with queued execution by applying new TaskQueue(), as well as wrap your exist Subjects with TaskQueue like new TaskQueue(ob$).

1const ob$ = new Subject()
2const subOb$ = new Subject()
3
4async function asyncFunc() {
5  await new Promise((resolve) => setTimeout(resolve, Math.random(1) * 1000))
6}
7
8// Without [TaskQueue]
9ob$.subscribe(x => {
10  subOb$.next(x)
11})
12subOb$.current.pipe(switchMap(asyncFunc)).subscribe()  // <- My main goal is to make sure the [asyncFunc] is executed asyncronously.
13
14// With [TaskQueue]
15const taskQueue = new TaskQueue(subOb$)
16ob$.subscribe(x => {
17  taskQueue.next(x)
18  // or
19  taskQueue.nextAsync(x)
20})
21taskQueue.subscribe(asyncFunc)