Renamed RxBlockingQueue to RxAsyncQueue, which has its own thread.