Terraria v1.4.4.9
Terraria source code documentation
Loading...
Searching...
No Matches
System.Threading.Tasks.Dataflow.BroadcastBlock< T > Class Template Referencesealed

Classes

class  BroadcastingSourceCore
 
class  DebugView
 

Public Member Functions

 BroadcastBlock (Func< T, T >? cloningFunction)
 
 BroadcastBlock (Func< T, T >? cloningFunction, DataflowBlockOptions dataflowBlockOptions)
 
void Complete ()
 
IDisposable LinkTo (ITargetBlock< T > target, DataflowLinkOptions linkOptions)
 
bool TryReceive (Predicate< T >? filter, [MaybeNullWhen(false)] out T item)
 
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 CompleteCore (Exception exception, bool storeExceptionEvenIfAlreadyCompleting, bool revertProcessingState=false)
 
void ConsumeAsyncIfNecessary (bool isReplacementReplica=false)
 

Properties

object IncomingLock [get]
 
Task Completion [get]
 
bool HasValueForDebugger [get]
 
T ValueForDebugger [get]
 
object DebuggerDisplayContent [get]
 
object IDebuggerDisplay. Content [get]
 

Private Member Functions

void IDataflowBlock. Fault (Exception exception)
 
bool IReceivableSourceBlock< T >. TryReceiveAll ([NotNullWhen(true)] out IList< T > items)
 
DataflowMessageStatus ITargetBlock< T >. OfferMessage (DataflowMessageHeader messageHeader, T messageValue, ISourceBlock< T > source, bool consumeToAccept)
 
void OnItemsRemoved (int numItemsRemoved)
 
void ConsumeMessagesLoopCore ()
 
bool ConsumeAndStoreOneMessageIfAvailable ()
 
void CompleteTargetIfPossible ()
 
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)
 

Private Attributes

readonly BroadcastingSourceCore< T_source
 
readonly BoundingStateWithPostponedAndTask< T_boundingState
 
bool _decliningPermanently
 
bool _completionReserved
 

Detailed Description

Definition at line 11 of file BroadcastBlock.cs.


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