BasicProducer<TSource> abstract class BasicProducer<TSource> : IProducer<TSource>, IObservable<TSource> Documentation Code protected BasicProducer() protected abstract IDisposable Run(IObserver<TSource> observer) public IDisposable Subscribe(IObserver<TSource> observer) public IDisposable SubscribeRaw(IObserver<TSource> observer, bool enableSafeguard)