Added syncronization to RxProcessorTest