IkvmToolDelegateDiagnosticListener.cs

Go to the documentation of this file.

using System;
using System.Threading;
using System.Threading.Tasks;
 
namespace IKVM.Tools.Runner.Diagnostics
{
 
    public class IkvmToolDelegateDiagnosticListener : IIkvmToolDiagnosticEventListener
    {
 
        readonly Func<IkvmToolDiagnosticEvent, CancellationToken, ValueTask> func;
 
        public IkvmToolDelegateDiagnosticListener(Func<IkvmToolDiagnosticEvent, CancellationToken, ValueTask> func)
        {
            this.func = func ?? throw new ArgumentNullException(nameof(func));
        }
 
        public IkvmToolDelegateDiagnosticListener(Action<IkvmToolDiagnosticEvent> action) :
            this((evt, cancellationToken) => { action(evt); return new ValueTask(Task.CompletedTask); })
        {
 
        }
 
        public ValueTask ReceiveAsync(IkvmToolDiagnosticEvent @event, CancellationToken cancellationToken)
        {
            return func(@event, cancellationToken);
        }
 
    }
 
}