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);
    }
}