Wrapper around _Observer_ that ensures compliance with the Rx contract. but ``` SafeSubscriber(Subscriber<? super T> actual) ``` The doc comments for `onNext` etc also mention `Observer` instead of `Subscriber`.