An async/await observer pattern implementation. Supports observing multiple publishers from a single observer.