Theodor Zoulias theodorzoulias

theodorzoulias / PressureAwareUnboundedChannel.cs

Last active May 3, 2022 09:07

PressureAwareUnboundedChannel -- https://stackoverflow.com/a/69284386/11178549

	using System;
	using System.Collections.Immutable;
	using System.Diagnostics;
	using System.Threading;
	using System.Threading.Channels;
	using System.Threading.Tasks;
	using System.Threading.Tasks.Dataflow;

	namespace CustomChannels
	{

theodorzoulias / gist:cc7f38d5423eee9f238f349605fc400a

Last active May 3, 2022 09:14

Nito.AsyncEx.AsyncAutoResetEvent.WaitAsync with timeout -- https://stackoverflow.com/questions/32654509/awaitable-autoresetevent

	public static async Task<bool> WaitAsync(this AsyncAutoResetEvent source,
	TimeSpan timeout, CancellationToken cancellationToken = default)
	{
	if (timeout < TimeSpan.Zero) throw new ArgumentOutOfRangeException(nameof(timeout));
	if (timeout == Timeout.InfiniteTimeSpan)
	{
	await source.WaitAsync(cancellationToken); return true;
	}

	cancellationToken.ThrowIfCancellationRequested();