https://cyounes.com/posts/observable-concurrent-queue/