I removed the synchronized. However, I'm still confused about concurrency in RxJava. Could you review my discussion in https://github.com/Netflix/RxJava/issues/417 and help me solve the problems?