Terraria v1.4.4.9
Terraria source code documentation
Loading...
Searching...
No Matches
System.Threading.Tasks.Dataflow.TransformBlock< TInput, TOutput > Class Template Referencesealed

Classes

class  DebugView
 

Public Member Functions

 TransformBlock (Func< TInput, TOutput > transform)
 
 TransformBlock (Func< TInput, TOutput > transform, ExecutionDataflowBlockOptions dataflowBlockOptions)
 
 TransformBlock (Func< TInput, Task< TOutput > > transform)
 
 TransformBlock (Func< TInput, Task< 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

 TransformBlock (Func< TInput, TOutput > transformSync, Func< TInput, Task< TOutput > > transformAsync, ExecutionDataflowBlockOptions dataflowBlockOptions)
 
void ProcessMessage (Func< TInput, TOutput > transform, KeyValuePair< TInput, long > messageWithId)
 
void ProcessMessageWithTask (Func< TInput, Task< TOutput > > transform, KeyValuePair< TInput, long > messageWithId)
 
void AsyncCompleteProcessMessageWithTask (Task< TOutput > completed, KeyValuePair< TInput, long > messageWithId)
 
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< TOutput > _reorderingBuffer
 
readonly SourceCore< TOutput > _source
 

Detailed Description

Definition at line 10 of file TransformBlock.cs.


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