DotNext.Threading by .NET Foundation and Contributors

API Diff between 4.14.1 and 5.5.0

22 Additions 6 Removals

DotNext.Collections.Concurrent

public struct IndexPool : ISupplier<int>, IFunctional<Func<int>>, IConsumer<int>, IFunctional<Action<int>>, IReadOnlyCollection<int>, IEnumerable<int>, IEnumerable, IResettable

DotNext.Threading

public class AsyncLazy<T> : ISupplier<CancellationToken, Task<T>>, IFunctional<Func<CancellationToken, Task<T>>>
- public Task<T> Task { get; }
- public AsyncLazy(Func<Task<T>> valueFactory, bool resettable = false)
- public ConfiguredTaskAwaitable<T> ConfigureAwait(bool continueOnCapturedContext)
- public TaskAwaiter<T> GetAwaiter()
public struct AsyncLock : IDisposable, IEquatable<AsyncLock>, IAsyncDisposable
- public ValueTask<Holder> TryAcquireAsync(CancellationToken token)
public static class AsyncLockAcquisition
- public static ValueTask<Holder> AcquireLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
- public static ValueTask<Holder> AcquireReadLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
- public static ValueTask<Holder> AcquireWriteLockAsync<T>(this T obj, TimeSpan timeout, CancellationToken token = default)
- public static ValueTask<Holder> SuppressCancellation(this ValueTask<Holder> result)
- public static ValueTask<Holder> SuppressDisposedState(this ValueTask<Holder> result)
- public static ValueTask<Holder> SuppressDisposedStateOrCancellation(this ValueTask<Holder> result)
public class AsyncTrigger<TState> : QueuedSynchronizer
- public interface ITransition<TState>
- public TState State { get; }
- public AsyncTrigger(TState state)
- public AsyncTrigger(TState state, int concurrencyLevel)
- public void Signal()
- public void Signal(Action<TState> transition)
- public void Signal<T>(Action<TState, T> transition, T arg)
- public bool TrySignal(ITransition<TState> transition)
- public ValueTask<bool> WaitAsync(ITransition<TState> transition, TimeSpan timeout, CancellationToken token = default)
- public ValueTask WaitAsync(ITransition<TState> transition, CancellationToken token = default)

DotNext.Threading.Channels

public sealed class PersistentChannelOptions : ChannelOptions
- public IncrementingEventCounter ReadRateCounter { get; set; }
- public IncrementingEventCounter WriteRateCounter { get; set; }

DotNext.Threading.Tasks

public static class TaskCompletionPipe
- public struct Consumer<T> : IAsyncEnumerable<T>
- public static Consumer<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)
- public static IAsyncEnumerable<T> GetConsumer<T>(this TaskCompletionPipe<Task<T>> pipe)