1 instantiation of SourceObservable
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2183return _table.GetValue(source, static s => new SourceObservable<TOutput>(s));
9 references to SourceObservable
System.Threading.Tasks.Dataflow (9)
Base\DataflowBlock.cs (9)
2156return SourceObservable<TOutput>.From(source); 2164[DebuggerTypeProxy(typeof(SourceObservable<>.DebugView))] 2174private static readonly ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>> _table = 2175new ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>>(); 2180internal static SourceObservable<TOutput> From(ISourceBlock<TOutput> source) 2333private readonly SourceObservable<TOutput> _observable; 2337public DebugView(SourceObservable<TOutput> observable) 2352internal readonly SourceObservable<TOutput> Observable; 2372internal ObserversState(SourceObservable<TOutput> observable)