Public Member Functions
IDisposable	Subscribe (IObserver< T > observer)

Package Functions
	SourceObservable (ISourceBlock< TOutput > source)

Static Package Functions
static IObservable< TOutput >	From (ISourceBlock< TOutput > source)

Properties
object	DebuggerDisplayContent `[get]`

object IDebuggerDisplay.	Content `[get]`

Private Member Functions
AggregateException	GetCompletionError ()

IDisposable IObservable< TOutput >.	Subscribe (IObserver< TOutput > observer)

void	Unsubscribe (IObserver< TOutput > observer)

ImmutableArray< IObserver< TOutput > >	ResetObserverState ()

Private Attributes
readonly object	_SubscriptionLock = new object()

readonly ISourceBlock< TOutput >	_source

ObserversState	_observersState

Static Private Attributes
static readonly ConditionalWeakTable< ISourceBlock< TOutput >, SourceObservable< TOutput > >	_table = new ConditionalWeakTable<ISourceBlock<TOutput>, SourceObservable<TOutput>>()

Detailed Description

Definition at line 903 of file DataflowBlock.cs.

The documentation for this class was generated from the following file:

source/System.Threading.Tasks.Dataflow/System.Threading.Tasks.Dataflow/DataflowBlock.cs

Classes