Public Member Functions
void	Complete ()

DataflowMessageStatus	OfferMessage (DataflowMessageHeader messageHeader, TInput messageValue, ISourceBlock< TInput >? source, bool consumeToAccept)

void	Complete ()

Properties
override bool	IsDecliningPermanently `[get]`

override bool	HasAtLeastOneMessageAvailable `[get]`

override bool	HasAtLeastOnePostponedMessage `[get]`

override int	NumberOfMessagesAvailableOrPostponed `[get]`

override bool	HasTheHighestNumberOfMessagesAvailable `[get]`

Task	Completion `[get]`

Task	CompletionTaskInternal `[get]`

int	InputCountForDebugger `[get]`

object	DebuggerDisplayContent `[get]`

object IDebuggerDisplay.	Content `[get]`

Private Member Functions
void	CompleteIfLastJoinIsFeasible ()

DataflowMessageStatus ITargetBlock< T >.	OfferMessage (DataflowMessageHeader messageHeader, T messageValue, ISourceBlock< T > source, bool consumeToAccept)

void IDataflowBlock.	Fault (Exception exception)

Private Attributes
readonly JoinBlockTargetSharedResources	_sharedResources

readonly TaskCompletionSource< VoidResult >	_completionTask = new TaskCompletionSource<VoidResult>()

readonly Queue< T >	_messages

readonly NonGreedyState	_nonGreedy

bool	_decliningPermanently

Detailed Description

Definition at line 8 of file JoinBlockTarget.cs.

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

source/System.Threading.Tasks.Dataflow/System.Threading.Tasks.Dataflow.Internal/JoinBlockTarget.cs

Package Functions
	JoinBlockTarget (JoinBlockTargetSharedResources sharedResources)

T	GetOneMessage ()

override bool	ReserveOneMessage ()

override bool	ConsumeReservedMessage ()

override bool	ConsumeOnePostponedMessage ()

override void	ReleaseReservedMessage ()

override void	ClearReservation ()

override void	CompleteOncePossible ()

override void	CompleteCore (Exception exception, bool dropPendingMessages, bool releaseReservedMessages)

Classes