IProducer<TSource> interface IProducer<TSource> : IObservable<TSource> Documentation Code IDisposable SubscribeRaw(IObserver<TSource> observer, bool enableSafeguard)