Terraria v1.4.4.9
Terraria source code documentation
Loading...
Searching...
No Matches
System.Threading.Tasks.Dataflow.Internal.Common Class Reference

Classes

class  CachedGenericDelegates
 

Package Functions

delegate bool KeepAlivePredicate< TStateIn, TStateOut > (TStateIn stateIn, out TStateOut stateOut)
 

Static Package Functions

static bool TryKeepAliveUntil< TStateIn, TStateOut > (KeepAlivePredicate< TStateIn, TStateOut > predicate, TStateIn stateIn, [MaybeNullWhen(false)] out TStateOut stateOut)
 
static T UnwrapWeakReference< T > (object state)
 
static int GetBlockId (IDataflowBlock block)
 
static string GetNameForDebugger (IDataflowBlock block, DataflowBlockOptions options=null)
 
static bool IsCooperativeCancellation (Exception exception)
 
static void WireCancellationToComplete (CancellationToken cancellationToken, Task completionTask, Action< object > completeAction, object completeState)
 
static Exception InitializeStackTrace (Exception exception)
 
static void StoreDataflowMessageValueIntoExceptionData< T > (Exception exc, T messageValue, bool targetInnerExceptions=false)
 
static void ThrowAsync (Exception error)
 
static void AddException ([NotNull] ref List< Exception > list, Exception exception, bool unwrapInnerExceptions=false)
 
static Task< TResultCreateTaskFromException< TResult > (Exception exception)
 
static Task< TResultCreateTaskFromCancellation< TResult > (CancellationToken cancellationToken)
 
static Task GetPotentiallyNotSupportedCompletionTask (IDataflowBlock block)
 
static IDisposable CreateUnlinker< TOutput > (object outgoingLock, TargetRegistry< TOutput > targetRegistry, ITargetBlock< TOutput > targetBlock)
 
static bool IsValidTimeout (TimeSpan timeout)
 
static TaskContinuationOptions GetContinuationOptions (TaskContinuationOptions toInclude=TaskContinuationOptions.None)
 
static TaskCreationOptions GetCreationOptionsForTask (bool isReplacementReplica=false)
 
static Exception StartTaskSafe (Task task, TaskScheduler scheduler)
 
static void ReleaseAllPostponedMessages< T > (ITargetBlock< T > target, QueuedMap< ISourceBlock< T >, DataflowMessageHeader > postponedMessages, ref List< Exception > exceptions)
 
static void PropagateCompletion (Task sourceCompletionTask, IDataflowBlock target, Action< Exception > exceptionHandler)
 
static void PropagateCompletionOnceCompleted (Task sourceCompletionTask, IDataflowBlock target)
 

Static Package Attributes

static readonly DataflowMessageHeader SingleMessageHeader = new DataflowMessageHeader(1L)
 
static readonly Task< boolCompletedTaskWithTrueResult = CreateCachedBooleanTask(value: true)
 
static readonly Task< boolCompletedTaskWithFalseResult = CreateCachedBooleanTask(value: false)
 
static readonly TaskCompletionSource< VoidResultCompletedVoidResultTaskCompletionSource = CreateCachedTaskCompletionSource<VoidResult>()
 
static readonly TimeSpan InfiniteTimeSpan = Timeout.InfiniteTimeSpan
 
static readonly Action< ExceptionAsyncExceptionHandler = ThrowAsync
 

Static Private Member Functions

static void StoreStringIntoExceptionData (Exception exception, string key, string value)
 
static Task< boolCreateCachedBooleanTask (bool value)
 
static TaskCompletionSource< TCreateCachedTaskCompletionSource< T > ()
 
static Exception StartTaskSafeCore (Task task, TaskScheduler scheduler)
 
static void PropagateCompletionAsContinuation (Task sourceCompletionTask, IDataflowBlock target)
 

Detailed Description

Definition at line 9 of file Common.cs.


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