DotNext.Threading by .NET Foundation and Contributors

API Diff between 4.0.0-beta.5 and 4.6.0

20 Additions 32 Removals

DotNext.Threading

public class AsyncCorrelationSource<TKey, TValue>
- public bool Pulse(TKey eventId, ref Result value)
- public bool Pulse(TKey eventId, ref Result value, out object userData)
- public bool Pulse(TKey eventId, TValue value)
- public ValueTask<TValue> WaitAsync(TKey eventId, object userData, TimeSpan timeout, CancellationToken token = default)
public class AsyncCounter : QueuedSynchronizer, IAsyncEvent, IDisposable
- public void Increment(long delta)
public class AsyncEventHub
public class AsyncLazy<T>
- public AsyncLazy(Func<CancellationToken, Task<T>> valueFactory, bool resettable = false)
- public Task<T> WithCancellation(CancellationToken token = default)
public class AsyncTrigger : QueuedSynchronizer, IAsyncEvent, IDisposable
- public Task WaitAsync<TStateMachine>(TStateMachine stateMachine, Predicate<TStateMachine> condition, CancellationToken token = default)
public abstract class LinkedCancellationTokenSource : CancellationTokenSource
public static class LinkedTokenSourceFactory
- public static LinkedCancellationTokenSource LinkTo(this ref CancellationToken first, CancellationToken second)
- public static CancellationTokenSource LinkTo(this ref CancellationToken first, CancellationToken second)
public class QueuedSynchronizer : Disposable
- public void Dispose(Exception reason)
- public IReadOnlyList<object> GetSuspendedCallers()
- public void SetCallerInformation(object information)
- public void TrackSuspendedCallers(Func<object> callerInfoProvider = null)
public static class Scheduler

DotNext.Threading.Channels

public sealed class PersistentChannelOptions : ChannelOptions
- public bool ReliableEnumeration { get; set; }

DotNext.Threading.Tasks

public abstract class ManualResetCompletionSource : IThreadPoolWorkItem
- protected object CompletionData { get; }
- public ManualResetCompletionSourceStatus Status { get; }
- public bool TryReset(out short token)
- public abstract bool TrySetCanceled(object completionData, CancellationToken token)
- public abstract bool TrySetException(object completionData, Exception e)
public enum ManualResetCompletionSourceStatus
public class TaskCompletionPipe<T> : IAsyncEnumerable<T> where T : Task
public class ValueTaskCompletionSource : ManualResetCompletionSource, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask>
- public TaskCompletionSource CreateLinkedTaskCompletionSource(object userData, TimeSpan timeout, CancellationToken token)
- public bool TrySetCanceled(object completionData, short completionToken, CancellationToken token)
- public bool TrySetException(object completionData, short completionToken, Exception e)
- public bool TrySetResult(object completionData)
- public bool TrySetResult(object completionData, short completionToken)
public class ValueTaskCompletionSource<T> : ManualResetCompletionSource, IValueTaskSource<T>, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask<T>>, ISupplier<TimeSpan, CancellationToken, ValueTask>
- public TaskCompletionSource<T> CreateLinkedTaskCompletionSource(object userData, TimeSpan timeout, CancellationToken token)
- public bool TrySetCanceled(object completionData, short completionToken, CancellationToken token)
- public bool TrySetException(object completionData, short completionToken, Exception e)
- public bool TrySetResult(object completionData, T value)
- public bool TrySetResult(object completionData, short completionToken, T value)
public static class ValueTaskSynchronization
- public static ValueTask WhenAll(ValueTask task1, ValueTask task2)
- public static ValueTask<ValueTuple<T1, T2>> WhenAll<T1, T2>(ValueTask<T1> task1, ValueTask<T2> task2)
- public static ValueTask WhenAll(ValueTask task1, ValueTask task2, ValueTask task3)
- public static ValueTask<ValueTuple<T1, T2, T3>> WhenAll<T1, T2, T3>(ValueTask<T1> task1, ValueTask<T2> task2, ValueTask<T3> task3)
- public static ValueTask WhenAll(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4)
- public static ValueTask<ValueTuple<T1, T2, T3, T4>> WhenAll<T1, T2, T3, T4>(ValueTask<T1> task1, ValueTask<T2> task2, ValueTask<T3> task3, ValueTask<T4> task4)
- public static ValueTask WhenAll(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4, ValueTask task5)
- public static ValueTask<ValueTuple<T1, T2, T3, T4, T5>> WhenAll<T1, T2, T3, T4, T5>(ValueTask<T1> task1, ValueTask<T2> task2, ValueTask<T3> task3, ValueTask<T4> task4, ValueTask<T5> task5)
- public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2)
- public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2)
- public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3)
- public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3)
- public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4)
- public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4)
- public static ValueTask<ValueTask> WhenAny(ValueTask task1, ValueTask task2, ValueTask task3, ValueTask task4, ValueTask task5)
- public static ValueTask<ValueTask<TResult>> WhenAny<TResult>(ValueTask<TResult> task1, ValueTask<TResult> task2, ValueTask<TResult> task3, ValueTask<TResult> task4, ValueTask<TResult> task5)