DotNext.Threading by .NET Foundation and Contributors

<PackageReference Include="DotNext.Threading" Version="4.2.0-beta.1" />

---

API Diff between 4.2.0-beta.1 and 4.0.0

26 Additions 1 Removals

DotNext.Threading

• public class AsyncCounter : QueuedSynchronizer, IAsyncEvent, IDisposable
  • public void Increment(long delta)
• public class AsyncEventHub
  • public void CaptureState(Span<bool> states)
• public class AsyncLazy<T> : ISupplier<CancellationToken, Task<T>>
  • public AsyncLazy(Func<CancellationToken, Task<T>> valueFactory, bool resettable = false)
  • public Task<T> WithCancellation(CancellationToken token = default)
• public class QueuedSynchronizer : Disposable
  • public void Dispose(Exception reason)
  • public void TrackSuspendedCallers()
  • public void TrackSuspendedCallers(Func<object> callerInfoProvider = null)

DotNext.Threading.Tasks

• public abstract class ManualResetCompletionSource : IThreadPoolWorkItem
  • protected object CompletionData { get; }
  • public abstract bool TrySetCanceled(object completionData, CancellationToken token)
  • public abstract bool TrySetException(object completionData, Exception e)
• public class TaskCompletionPipe<T> : IAsyncEnumerable<T> where T : Task
  • public TaskCompletionPipe(int capacity = 0)
  • public void Add(T task)
  • public void Complete()
  • public IAsyncEnumerator<T> GetAsyncEnumerator(CancellationToken token)
  • public void Reset(int capacity = 0)
  • public bool TryRead(out T task)
  • public ValueTask<bool> WaitToReadAsync(TimeSpan timeout, CancellationToken token = default)
  • public ValueTask<bool> WaitToReadAsync(CancellationToken token = default)
• public class ValueTaskCompletionSource : ManualResetCompletionSource, IValueTaskSource, ISupplier<TimeSpan, CancellationToken, ValueTask>
  • 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>, ISupplier<TimeSpan, CancellationToken, ValueTask<T>>
  • 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)