DiagnosticChannelProvider.cs

Go to the documentation of this file.

using System;
using System.Collections.Concurrent;
using System.Collections.Generic;
using System.Linq;
 
namespace IKVM.Tools.Core.Diagnostics
{
 
    class DiagnosticChannelProvider : IDisposable
    {
 
        readonly IEnumerable<IDiagnosticChannelFactory> _factories;
        readonly ConcurrentDictionary<string, IDiagnosticChannel?> _cache = new();
 
        public DiagnosticChannelProvider(IEnumerable<IDiagnosticChannelFactory> factories)
        {
            _factories = factories ?? throw new ArgumentNullException(nameof(factories));
        }
 
        public IDiagnosticChannel? GetOrCreateChannel(string spec)
        {
            return _cache.GetOrAdd(spec, _ => _factories.Select(i => i.CreateChannel(_)).FirstOrDefault(i => i != null));
        }
 
        public void Dispose()
        {
            foreach (var i in _cache.Values)
                if (i is IDisposable d)
                    d.Dispose();
 
            _cache.Clear();
        }
 
    }
 
}