using System.Collections.Generic; using System.Runtime.CompilerServices; namespace System.Reactive.Joins { [System.Runtime.CompilerServices.NullableContext(1)] [System.Runtime.CompilerServices.Nullable(0)] internal abstract class ActivePlan { private readonly Dictionary<System.Reactive.Joins.IJoinObserver, System.Reactive.Joins.IJoinObserver> _joinObservers = new Dictionary<System.Reactive.Joins.IJoinObserver, System.Reactive.Joins.IJoinObserver>(); protected readonly Action _onCompleted; internal abstract void Match(); protected ActivePlan(Action onCompleted) { _onCompleted = onCompleted; } protected void AddJoinObserver(System.Reactive.Joins.IJoinObserver joinObserver) { if (!_joinObservers.ContainsKey(joinObserver)) _joinObservers.Add(joinObserver, joinObserver); } protected void Dequeue() { foreach (System.Reactive.Joins.IJoinObserver value in _joinObservers.Values) { value.Dequeue(); } } } }