Non-blocking implementation of ScheduledObserver