1 instantiation of SourceObservable
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2185return _table.GetValue(source, static s => new SourceObservable<TOutput>(s));
9 references to SourceObservable
System.Threading.Tasks.Dataflow (9)
Base\DataflowBlock.cs (9)
2158return SourceObservable<TOutput>.From(source); 2166[DebuggerTypeProxy(typeof(SourceObservable<>.DebugView))] 2176private static readonly ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>> _table = 2177new ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>>(); 2182internal static SourceObservable<TOutput> From(ISourceBlock<TOutput> source) 2335private readonly SourceObservable<TOutput> _observable; 2339public DebugView(SourceObservable<TOutput> observable) 2354internal readonly SourceObservable<TOutput> Observable; 2374internal ObserversState(SourceObservable<TOutput> observable)