Classes
class	DebugView

Public Member Functions
	TransformManyBlock (Func< TInput, IEnumerable< TOutput > > transform)

	TransformManyBlock (Func< TInput, IEnumerable< TOutput > > transform, ExecutionDataflowBlockOptions dataflowBlockOptions)

	TransformManyBlock (Func< TInput, Task< IEnumerable< TOutput > > > transform)

	TransformManyBlock (Func< TInput, Task< IEnumerable< TOutput > > > transform, ExecutionDataflowBlockOptions dataflowBlockOptions)

void	Complete ()

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

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

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

override string	ToString ()

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

Properties
object	ParallelSourceLock `[get]`

Task	Completion `[get]`

int	InputCount `[get]`

int	OutputCount `[get]`

int	InputCountForDebugger `[get]`

int	OutputCountForDebugger `[get]`

object	DebuggerDisplayContent `[get]`

object IDebuggerDisplay.	Content `[get]`

Private Member Functions
	TransformManyBlock (Func< TInput, IEnumerable< TOutput > > transformSync, Func< TInput, Task< IEnumerable< TOutput > > > transformAsync, ExecutionDataflowBlockOptions dataflowBlockOptions)

void	ProcessMessage (Func< TInput, IEnumerable< TOutput > > transformFunction, KeyValuePair< TInput, long > messageWithId)

void	ProcessMessageWithTask (Func< TInput, Task< IEnumerable< TOutput > > > function, KeyValuePair< TInput, long > messageWithId)

void	AsyncCompleteProcessMessageWithTask (Task< IEnumerable< TOutput > > completed, KeyValuePair< TInput, long > messageWithId)

void	StoreOutputItems (KeyValuePair< TInput, long > messageWithId, IEnumerable< TOutput > outputItems)

void	StoreOutputItemsReordered (long id, IEnumerable< TOutput > item)

void	StoreOutputItemsNonReorderedAtomic (IEnumerable< TOutput > outputItems)

void	StoreOutputItemsNonReorderedWithIteration (IEnumerable< TOutput > outputItems)

void	UpdateBoundingCountWithOutputCount (int count)

void IDataflowBlock.	Fault (Exception exception)

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

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

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

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

Private Attributes
readonly TargetCore< TInput >	_target

readonly ReorderingBuffer< IEnumerable< TOutput > >	_reorderingBuffer

readonly SourceCore< TOutput >	_source

Detailed Description

Definition at line 11 of file TransformManyBlock.cs.

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

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

Classes

Public Member Functions

Properties

Private Member Functions

Private Attributes

Detailed Description