1 instantiation of SourceObservable
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2267return _table.GetValue(source, static s => new SourceObservable<TOutput>(s));
9 references to SourceObservable
System.Threading.Tasks.Dataflow (9)
Base\DataflowBlock.cs (9)
2240return SourceObservable<TOutput>.From(source); 2248[DebuggerTypeProxy(typeof(SourceObservable<>.DebugView))] 2258private static readonly ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>> _table = 2259new ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>>(); 2264internal static SourceObservable<TOutput> From(ISourceBlock<TOutput> source) 2420private readonly SourceObservable<TOutput> _observable; 2424public DebugView(SourceObservable<TOutput> observable) 2439internal readonly SourceObservable<TOutput> Observable; 2459internal ObserversState(SourceObservable<TOutput> observable)