Concurrency Fixes for RxRingBuffer & Merge