Terraria v1.4.4.9
Terraria source code documentation
Loading...
Searching...
No Matches
System.Threading.Tasks.Dataflow.BatchedJoinBlock< T1, T2, T3 > Class Template Referencesealed

Classes

class  DebugView
 

Public Member Functions

 BatchedJoinBlock (int batchSize)
 
 BatchedJoinBlock (int batchSize, GroupingDataflowBlockOptions dataflowBlockOptions)
 
IDisposable LinkTo (ITargetBlock< Tuple< IList< T1 >, IList< T2 > > > target, DataflowLinkOptions linkOptions)
 
bool TryReceive (Predicate< Tuple< IList< T1 >, IList< T2 > > >? filter, [NotNullWhen(true)] out Tuple< IList< T1 >, IList< T2 > >? item)
 
bool TryReceiveAll ([NotNullWhen(true)] out IList< Tuple< IList< T1 >, IList< T2 > > >? items)
 
void Complete ()
 
override string ToString ()
 
 BatchedJoinBlock (int batchSize)
 
 BatchedJoinBlock (int batchSize, GroupingDataflowBlockOptions dataflowBlockOptions)
 
IDisposable LinkTo (ITargetBlock< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > > target, DataflowLinkOptions linkOptions)
 
bool TryReceive (Predicate< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > >? filter, [NotNullWhen(true)] out Tuple< IList< T1 >, IList< T2 >, IList< T3 > >? item)
 
bool TryReceiveAll ([NotNullWhen(true)] out IList< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > >? items)
 
void Complete ()
 
override string ToString ()
 
bool TryReceive (Predicate< TOutput >? filter,[MaybeNullWhen(false)] out TOutput item)
 
bool TryReceiveAll ([NotNullWhen(true)] out IList< TOutput >? items)
 
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)
 
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)
 

Properties

int BatchSize [get]
 
ITargetBlock< T1 > Target1 [get]
 
ITargetBlock< T2 > Target2 [get]
 
int OutputCount [get]
 
Task Completion [get]
 
int OutputCountForDebugger [get]
 
object DebuggerDisplayContent [get]
 
object IDebuggerDisplay. Content [get]
 
ITargetBlock< T3 > Target3 [get]
 

Private Member Functions

void IDataflowBlock. Fault (Exception exception)
 
Tuple< IList< T1 >, IList< T2 > > ISourceBlock< Tuple< IList< T1 >, IList< T2 > > >. ConsumeMessage (DataflowMessageHeader messageHeader, ITargetBlock< Tuple< IList< T1 >, IList< T2 > > > target, out bool messageConsumed)
 
bool ISourceBlock< Tuple< IList< T1 >, IList< T2 > > >. ReserveMessage (DataflowMessageHeader messageHeader, ITargetBlock< Tuple< IList< T1 >, IList< T2 > > > target)
 
void ISourceBlock< Tuple< IList< T1 >, IList< T2 > > >. ReleaseReservation (DataflowMessageHeader messageHeader, ITargetBlock< Tuple< IList< T1 >, IList< T2 > > > target)
 
void CompleteEachTarget ()
 
void IDataflowBlock. Fault (Exception exception)
 
Tuple< IList< T1 >, IList< T2 >, IList< T3 > > ISourceBlock< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > >. ConsumeMessage (DataflowMessageHeader messageHeader, ITargetBlock< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > > target, out bool messageConsumed)
 
bool ISourceBlock< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > >. ReserveMessage (DataflowMessageHeader messageHeader, ITargetBlock< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > > target)
 
void ISourceBlock< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > >. ReleaseReservation (DataflowMessageHeader messageHeader, ITargetBlock< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > > target)
 
void CompleteEachTarget ()
 

Private Attributes

readonly int _batchSize
 
readonly BatchedJoinBlockTargetSharedResources _sharedResources
 
readonly BatchedJoinBlockTarget< T1 > _target1
 
readonly BatchedJoinBlockTarget< T2 > _target2
 
readonly SourceCore< Tuple< IList< T1 >, IList< T2 > > > _source
 
readonly BatchedJoinBlockTarget< T3 > _target3
 
readonly SourceCore< Tuple< IList< T1 >, IList< T2 >, IList< T3 > > > _source
 

Detailed Description

Definition at line 199 of file BatchedJoinBlock.cs.


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