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