HandleableCollection.cs (8)
24private static readonly Handler DefaultHandler = (T item, out bool removeItem) => { removeItem = true; return true; };
27private readonly List<Tuple<TaskCompletionSource<T>, Handler>> _handlers = new();
84foreach (Tuple<TaskCompletionSource<T>, Handler> tuple in _handlers)
108Tuple<TaskCompletionSource<T>, Handler> handler = _handlers[i];
139public T Handle(Handler handler, TimeSpan timeout)
174public async Task<T> HandleAsync(Handler handler, CancellationToken token)
184private void RunOrQueueHandler(Handler handler, TaskCompletionSource<T> completionSource)
213private static bool TryHandler(in T item, Handler handler, TaskCompletionSource<T> completionSource, out bool removeItem)