<PackageReference Include="System.Reactive" Version="6.0.0-preview.1" />
    
    
	
	
		
		
		
	 
	
	
        
                
                IScheduledObserver<T>
                
                
                
                
using System.
Runtime.
CompilerServices;
namespace System.
Reactive
{
    
internal interface IScheduledObserver<[
System.
Runtime.
CompilerServices.
Nullable(
2)] 
T> : 
IObserver<
T>, 
IDisposable
    {
        
void EnsureActive();
        
void EnsureActive(
int count);
    }
}