1 instantiation of SourceObservable
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlock.cs (1)
2186return _table.GetValue(source, static s => new SourceObservable<TOutput>(s));
9 references to SourceObservable
System.Threading.Tasks.Dataflow (9)
Base\DataflowBlock.cs (9)
2159return SourceObservable<TOutput>.From(source); 2167[DebuggerTypeProxy(typeof(SourceObservable<>.DebugView))] 2177private static readonly ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>> _table = 2178new ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>>(); 2183internal static SourceObservable<TOutput> From(ISourceBlock<TOutput> source) 2336private readonly SourceObservable<TOutput> _observable; 2340public DebugView(SourceObservable<TOutput> observable) 2355internal readonly SourceObservable<TOutput> Observable; 2375internal ObserversState(SourceObservable<TOutput> observable)