JoinObserver<T> sealed class JoinObserver<T> : ObserverBase<Notification<T>>, IJoinObserver, IDisposable Documentation Code public Queue<Notification<T>> Queue { get; } public JoinObserver(IObservable<T> source, Action<Exception> onError) public void AddActivePlan(ActivePlan activePlan) public void Dequeue() public void Subscribe(object gate)