<PackageReference Include="System.Reactive" Version="6.0.2" />

BasicProducer<TSource>

abstract class BasicProducer<TSource> : IProducer<TSource>, IObservable<TSource>
Base class for implementation of query operators, providing performance benefits over the use of Observable.Create.
protected BasicProducer()

protected abstract IDisposable Run(IObserver<TSource> observer)

Core implementation of the query operator, called upon a new subscription to the producer object.

public IDisposable Subscribe(IObserver<TSource> observer)

Publicly visible Subscribe method.

public IDisposable SubscribeRaw(IObserver<TSource> observer, bool enableSafeguard)