Fix SubscriberAsObserver implementation