using System.Collections.Generic; using System.Runtime.CompilerServices; namespace System.Reactive.Joins { [System.Runtime.CompilerServices.NullableContext(1)] [System.Runtime.CompilerServices.Nullable(0)] public abstract class Plan<[System.Runtime.CompilerServices.Nullable(2)] TResult> { internal Plan() { } internal abstract System.Reactive.Joins.ActivePlan Activate(Dictionary<object, System.Reactive.Joins.IJoinObserver> externalSubscriptions, IObserver<TResult> observer, Action<System.Reactive.Joins.ActivePlan> deactivate); internal static System.Reactive.Joins.JoinObserver<TSource> CreateObserver<[System.Runtime.CompilerServices.Nullable(2)] TSource>(Dictionary<object, System.Reactive.Joins.IJoinObserver> externalSubscriptions, IObservable<TSource> observable, Action<Exception> onError) { System.Reactive.Joins.JoinObserver<TSource> joinObserver; if (!externalSubscriptions.TryGetValue((object)observable, out System.Reactive.Joins.IJoinObserver value)) { joinObserver = new System.Reactive.Joins.JoinObserver<TSource>(observable, onError); externalSubscriptions.Add((object)observable, (System.Reactive.Joins.IJoinObserver)joinObserver); } else joinObserver = (System.Reactive.Joins.JoinObserver<TSource>)value; return joinObserver; } } }