Merge with Serialize - Handle Bad Observables

- concurrency unit tests
- handle Observable that emits onComplete multiple times

See https://github.com/Netflix/RxJava/pull/962#issuecomment-38191868