Split Take and TakeWhile
Implement TrustedObservableTester.assertTrustedObservable()
Fix violations of the Observer contract.