[main] Update dependencies from dotnet/efcore, dotnet/runtime

src/SignalR/clients/csharp/Client.Core/src/HubConnection.cs

@@ -829,12 +829,22 @@ private void LaunchStreams(ConnectionState connectionState, Dictionary<string, o
             {
                 _ = _sendIAsyncStreamItemsMethod
                     .MakeGenericMethod(reader.GetType().GetInterface("IAsyncEnumerable`1")!.GetGenericArguments())
-                    .Invoke(this, new object[] { connectionState, kvp.Key.ToString(), reader, cts });
+                    .Invoke(this, [connectionState, kvp.Key.ToString(), reader, cts]);
                 continue;
             }
-            _ = _sendStreamItemsMethod
-                .MakeGenericMethod(reader.GetType().GetGenericArguments())
-                .Invoke(this, new object[] { connectionState, kvp.Key.ToString(), reader, cts });
+            else
+            {
+                if (ReflectionHelper.TryGetStreamType(reader.GetType(), out var channelGenericType))
+                {
+                    _ = _sendStreamItemsMethod
+                        .MakeGenericMethod(channelGenericType)
+                        .Invoke(this, [connectionState, kvp.Key.ToString(), reader, cts]);
+                    continue;
+                }
+
+                // Should never get here, we should have already verified the stream types when the user initially calls send/invoke
+                throw new InvalidOperationException($"{reader.GetType()} is not a {typeof(ChannelReader<>).Name}.");
+            }
         }
     }
 

src/SignalR/common/Shared/ReflectionHelper.cs

@@ -2,7 +2,9 @@
 // The .NET Foundation licenses this file to you under the MIT license.
 
 using System;
+using System.Collections.Concurrent;
 using System.Collections.Generic;
+using System.Diagnostics;
 using System.Diagnostics.CodeAnalysis;
 using System.Linq;
 using System.Threading.Channels;
@@ -11,6 +13,8 @@ namespace Microsoft.AspNetCore.SignalR;
 
 internal static class ReflectionHelper
 {
+    private static ConcurrentDictionary<Type, Type> _streamTypeLookup = new();
+
     // mustBeDirectType - Hub methods must use the base 'stream' type and not be a derived class that just implements the 'stream' type
     // and 'stream' types from the client are allowed to inherit from accepted 'stream' types
     public static bool IsStreamingType([DynamicallyAccessedMembers(DynamicallyAccessedMemberTypes.Interfaces)] Type type, bool mustBeDirectType = false)
@@ -28,6 +32,9 @@ public static bool IsStreamingType([DynamicallyAccessedMembers(DynamicallyAccess
         {
             if (nullableType.IsGenericType && nullableType.GetGenericTypeDefinition() == typeof(ChannelReader<>))
             {
+                Debug.Assert(nullableType.GetGenericArguments().Length == 1);
+
+                _streamTypeLookup.GetOrAdd(type, nullableType.GetGenericArguments()[0]);
                 return true;
             }
 
@@ -59,4 +66,7 @@ public static bool IsIAsyncEnumerable([DynamicallyAccessedMembers(DynamicallyAcc
             }
         });
     }
+
+    public static bool TryGetStreamType(Type stream, [NotNullWhen(true)] out Type? streamType)
+        => _streamTypeLookup.TryGetValue(stream, out streamType);
 }