<PackageReference Include="System.Reactive" Version="7.0.0-preview.1" />
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();
}
}