Update ChannelFactory.cs

frankhaugen · Feb 2, 2024 · d201fdb · d201fdb
1 parent f3d047f
commit d201fdb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/Frank.Channels.DependencyInjection/ChannelFactory.cs b/Frank.Channels.DependencyInjection/ChannelFactory.cs
@@ -7,12 +7,12 @@ public class ChannelFactory : IChannelFactory
 {
     private readonly ConcurrentDictionary<string, object> _cache = new();
 
-    public Channel<T> CreateChannel<T>() where T : class => _cache.GetOrAdd(nameof(T), Value<T>) as Channel<T> ?? throw new InvalidOperationException($"{nameof(Channel<T>)} not found");
+    public Channel<T> CreateChannel<T>() where T : class => _cache.GetOrAdd(typeof(T).Name, Value<T>) as Channel<T> ?? throw new InvalidOperationException($"Channel<{typeof(T).Name}> not found");
 
     private static Channel<T> Value<T>(string arg) where T : class =>
         Channel.CreateUnbounded<T>(new UnboundedChannelOptions()
         {
             SingleReader = true,
             SingleWriter = true
         });
-}
+}