Public Member Functions
	BufferBlock ()

	BufferBlock (DataflowBlockOptions dataflowBlockOptions)

void	Complete ()

IDisposable	LinkTo (ITargetBlock< T > target, DataflowLinkOptions linkOptions)

bool	TryReceive (Predicate< T >? filter, [MaybeNullWhen(false)] out T item)

bool	TryReceiveAll ([NotNullWhen(true)] out IList< T >? items)

override string	ToString ()

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

IDisposable	LinkTo (ITargetBlock< TOutput > target, DataflowLinkOptions linkOptions)

TOutput?	ConsumeMessage (DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target, out bool messageConsumed)

bool	ReserveMessage (DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target)

void	ReleaseReservation (DataflowMessageHeader messageHeader, ITargetBlock< TOutput > target)

bool	TryReceive (Predicate< TOutput >? filter,[MaybeNullWhen(false)] out TOutput item)

bool	TryReceiveAll ([NotNullWhen(true)] out IList< TOutput >? items)

Package Functions
void	ConsumeAsyncIfNecessary (bool isReplacementReplica=false)

Properties
object	IncomingLock `[get]`

int	Count `[get]`

Task	Completion `[get]`

int	CountForDebugger `[get]`

object	DebuggerDisplayContent `[get]`

object IDebuggerDisplay.	Content `[get]`

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

void IDataflowBlock.	Fault (Exception exception)

void	CompleteCore (Exception exception, bool storeExceptionEvenIfAlreadyCompleting, bool revertProcessingState=false)

T ISourceBlock< T >.	ConsumeMessage (DataflowMessageHeader messageHeader, ITargetBlock< T > target, out bool messageConsumed)

bool ISourceBlock< T >.	ReserveMessage (DataflowMessageHeader messageHeader, ITargetBlock< T > target)

void ISourceBlock< T >.	ReleaseReservation (DataflowMessageHeader messageHeader, ITargetBlock< T > target)

void	OnItemsRemoved (int numItemsRemoved)

void	ConsumeMessagesLoopCore ()

bool	ConsumeAndStoreOneMessageIfAvailable ()

void	CompleteTargetIfPossible ()

Private Attributes
readonly SourceCore< T >	_source

readonly BoundingStateWithPostponedAndTask< T >	_boundingState

bool	_targetDecliningPermanently

bool	_targetCompletionReserved

Detailed Description

Definition at line 10 of file BufferBlock.cs.

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

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

Classes