System.Reactive.Joins.ActivePlan
namespace System.
Reactive.
Joins
{
internal abstract class ActivePlan
{
protected readonly Action _onCompleted;
protected ActivePlan(
Action onCompleted);
protected void AddJoinObserver(
IJoinObserver joinObserver);
protected void Dequeue();
}
}