Class ValueTaskCompletionSource

Represents the producer side of ValueTask.

Inheritance

object

ManualResetCompletionSource

ValueTaskCompletionSource

Implements

IValueTaskSource

ISupplier<TimeSpan, CancellationToken, ValueTask>

IFunctional<Func<TimeSpan, CancellationToken, ValueTask>>

Inherited Members

ManualResetCompletionSource.InitialCompletionToken

ManualResetCompletionSource.Reset()

ManualResetCompletionSource.TryReset(out short)

ManualResetCompletionSource.AfterConsumed()

ManualResetCompletionSource.CompletionData

ManualResetCompletionSource.TrySetException(Exception)

ManualResetCompletionSource.TrySetCanceled(CancellationToken)

ManualResetCompletionSource.Status

ManualResetCompletionSource.IsCompleted

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: DotNext.Threading.Tasks

Assembly: DotNext.Threading.dll

Syntax

public class ValueTaskCompletionSource : ManualResetCompletionSource, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask>, IFunctional<Func<TimeSpan, CancellationToken, ValueTask>>

Remarks

See description of ValueTaskCompletionSource<T> for more information about behavior of the completion source.

Constructors

ValueTaskCompletionSource(bool)

Initializes a new completion source.

Declaration

public ValueTaskCompletionSource(bool runContinuationsAsynchronously = true)

Parameters

Type	Name	Description
bool	runContinuationsAsynchronously	Indicates that continuations must be executed asynchronously.

Methods

CleanUp()

Resets internal state of this source.

Declaration

protected override void CleanUp()

Overrides

ManualResetCompletionSource.CleanUp()

CreateLinkedTaskCompletionSource(object?, TimeSpan, CancellationToken)

Creates a linked TaskCompletionSource that can be used cooperatively to complete the task.

Declaration

public TaskCompletionSource CreateLinkedTaskCompletionSource(object? userData, TimeSpan timeout, CancellationToken token)

Parameters

Type	Name	Description
object	userData	The custom data to be associated with the current version of the task.
TimeSpan	timeout	The timeout associated with the task.
CancellationToken	token	The cancellation token that can be used to cancel the task.

Returns

Type	Description
TaskCompletionSource	A linked TaskCompletionSource.

Exceptions

Type	Condition
InvalidOperationException	The source is in invalid state.

CreateTask(TimeSpan, CancellationToken)

Creates a fresh task linked with this source.

Declaration

public ValueTask CreateTask(TimeSpan timeout, CancellationToken token)

Parameters

Type	Name	Description
TimeSpan	timeout	The timeout associated with the task.
CancellationToken	token	The cancellation token that can be used to cancel the task.

Returns

Type	Description
ValueTask	A fresh uncompleted task.

Remarks

This method must be called after Reset().

Exceptions

Type	Condition
ArgumentOutOfRangeException	timeout is less than zero but not equals to InfiniteTimeSpan.
InvalidOperationException	The source is in invalid state.

OnCanceled(CancellationToken)

Called automatically when cancellation detected.

Declaration

protected virtual Exception? OnCanceled(CancellationToken token)

Parameters

Type	Name	Description
CancellationToken	token	The token representing cancellation reason.

Returns

Type	Description
Exception	The exception representing task result; or null to complete successfully.

Remarks

By default, this method returns OperationCanceledException as the task result.

OnTimeout()

Called automatically when timeout detected.

Declaration

protected virtual Exception? OnTimeout()

Returns

Type	Description
Exception	The exception representing task result; or null to complete successfully.

Remarks

By default, this method returns TimeoutException as the task result.

TrySetCanceled(short, CancellationToken)

Attempts to complete the task unsuccessfully.

Declaration

public bool TrySetCanceled(short completionToken, CancellationToken token)

Parameters

Type	Name	Description
short	completionToken	The completion token previously obtained from CreateTask(TimeSpan, CancellationToken) method.
CancellationToken	token	The canceled token.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

TrySetCanceled(object?, short, CancellationToken)

Attempts to complete the task unsuccessfully.

Declaration

public bool TrySetCanceled(object? completionData, short completionToken, CancellationToken token)

Parameters

Type	Name	Description
object	completionData	The data to be saved in CompletionData property that can be accessed from within AfterConsumed() method.
short	completionToken	The completion token previously obtained from CreateTask(TimeSpan, CancellationToken) method.
CancellationToken	token	The canceled token.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

TrySetCanceled(object?, CancellationToken)

Attempts to complete the task unsuccessfully.

Declaration

public override sealed bool TrySetCanceled(object? completionData, CancellationToken token)

Parameters

Type	Name	Description
object	completionData	The data to be saved in CompletionData property that can be accessed from within AfterConsumed() method.
CancellationToken	token	The canceled token.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

Overrides

ManualResetCompletionSource.TrySetCanceled(object?, CancellationToken)

TrySetException(short, Exception)

Attempts to complete the task unsuccessfully.

Declaration

public bool TrySetException(short completionToken, Exception e)

Parameters

Type	Name	Description
short	completionToken	The completion token previously obtained from CreateTask(TimeSpan, CancellationToken) method.
Exception	e	The exception to be returned to the consumer.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

TrySetException(object?, Exception)

Attempts to complete the task unsuccessfully.

Declaration

public override sealed bool TrySetException(object? completionData, Exception e)

Parameters

Type	Name	Description
object	completionData	The data to be saved in CompletionData property that can be accessed from within AfterConsumed() method.
Exception	e	The exception to be returned to the consumer.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

Overrides

ManualResetCompletionSource.TrySetException(object?, Exception)

TrySetException(object?, short, Exception)

Attempts to complete the task unsuccessfully.

Declaration

public bool TrySetException(object? completionData, short completionToken, Exception e)

Parameters

Type	Name	Description
object	completionData	The data to be saved in CompletionData property that can be accessed from within AfterConsumed() method.
short	completionToken	The completion token previously obtained from CreateTask(TimeSpan, CancellationToken) method.
Exception	e	The exception to be returned to the consumer.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

TrySetResult()

Attempts to complete the task successfully.

Declaration

public bool TrySetResult()

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

TrySetResult(short)

Attempts to complete the task successfully.

Declaration

public bool TrySetResult(short completionToken)

Parameters

Type	Name	Description
short	completionToken	The completion token previously obtained from CreateTask(TimeSpan, CancellationToken) method.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

TrySetResult(object?)

Attempts to complete the task successfully.

Declaration

public bool TrySetResult(object? completionData)

Parameters

Type	Name	Description
object	completionData	The data to be saved in CompletionData property that can be accessed from within AfterConsumed() method.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

TrySetResult(object?, short)

Attempts to complete the task successfully.

Declaration

public bool TrySetResult(object? completionData, short completionToken)

Parameters

Type	Name	Description
object	completionData	The data to be saved in CompletionData property that can be accessed from within AfterConsumed() method.
short	completionToken	The completion token previously obtained from CreateTask(TimeSpan, CancellationToken) method.

Returns

Type	Description
bool	true if the result is completed successfully; false if the task has been canceled or timed out.

Implements

IValueTaskSource

ISupplier<T1, T2, TResult>

IFunctional<TDelegate>

Extension Methods

BasicExtensions.As<T>(T)

BasicExtensions.GetUserData<T>(T)

BasicExtensions.IsBetween<T, TLowerBound, TUpperBound>(T, TLowerBound, TUpperBound)

BasicExtensions.IsOneOf<T>(T, ReadOnlySpan<T>)

ExpressionBuilder.Const<T>(T)

AsyncLockAcquisition.AcquireLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireLockAsync<T>(T, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireReadLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireReadLockAsync<T>(T, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, bool, TimeSpan, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, CancellationToken)

AsyncLockAcquisition.AcquireWriteLockAsync<T>(T, TimeSpan, CancellationToken)

LockAcquisition.AcquireReadLock<T>(T)

LockAcquisition.AcquireReadLock<T>(T, TimeSpan)

LockAcquisition.AcquireUpgradeableReadLock<T>(T)

LockAcquisition.AcquireUpgradeableReadLock<T>(T, TimeSpan)

LockAcquisition.AcquireWriteLock<T>(T)

LockAcquisition.AcquireWriteLock<T>(T, TimeSpan)

See Also

ValueTaskCompletionSource<T>