Netflix/RxJava — pull request #1010 by benjchristensen (2014-04-02 06:04:38+00:00)
Title: UnsafeSubscribe

Migrate from reflection to unsafeSubscribe as per discussion at https://github.com/Netflix/RxJava/issues/676

All operators are migrated to using `unsafeSubscribe` instead of relying on their package to avoid `SafeSubscriber` wrapping.

NOTE: With these changes I'm seeing non-deterministic failure of `OperatorGroupByTest.testStaggeredCompletion`. It's not yet clear why.