58 references to StreamingHub
Microsoft.AspNetCore.SignalR.Tests (58)
HubConnectionHandlerTests.Activity.cs (13)
118var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 127AssertHubMethodActivity<StreamingHub>(activity, nameof(StreamingHub.OnConnectedAsync), mockHttpRequestActivity); 129_ = await client.StreamAsync(nameof(StreamingHub.CounterChannel), 3).DefaultTimeout(); 132AssertHubMethodActivity<StreamingHub>(activities[1], nameof(StreamingHub.CounterChannel), mockHttpRequestActivity); 137AssertHubMethodActivity<StreamingHub>(activities[2], "RenamedCounterChannel", mockHttpRequestActivity); 145AssertHubMethodActivity<StreamingHub>(activities[3], nameof(StreamingHub.OnDisconnectedAsync), mockHttpRequestActivity); 281var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 287_ = await client.StreamAsync(nameof(StreamingHub.ExceptionAsyncEnumerable)).DefaultTimeout(); 291AssertHubMethodActivity<StreamingHub>(activity, nameof(StreamingHub.ExceptionAsyncEnumerable),
HubConnectionHandlerTests.cs (45)
2010var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 2045var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 2054await client.SendHubMessageAsync(new StreamInvocationMessage(invocationId, nameof(StreamingHub.BlockingStream), Array.Empty<object>())); 2071[InlineData(nameof(StreamingHub.ExceptionAsyncEnumerable), "Exception: Exception from async enumerable")] 2072[InlineData(nameof(StreamingHub.ExceptionAsyncEnumerable), null)] 2073[InlineData(nameof(StreamingHub.ExceptionStream), "Exception: Exception from channel")] 2074[InlineData(nameof(StreamingHub.ExceptionStream), null)] 2075[InlineData(nameof(StreamingHub.ChannelClosedExceptionStream), "ChannelClosedException: ChannelClosedException from channel")] 2076[InlineData(nameof(StreamingHub.ChannelClosedExceptionStream), null)] 2077[InlineData(nameof(StreamingHub.ChannelClosedExceptionInnerExceptionStream), "Exception: ChannelClosedException from channel")] 2078[InlineData(nameof(StreamingHub.ChannelClosedExceptionInnerExceptionStream), null)] 2094var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 2169nameof(StreamingHub.CounterChannel), 2170nameof(StreamingHub.CounterChannelAsync), 2171nameof(StreamingHub.CounterChannelValueTaskAsync), 2172nameof(StreamingHub.CounterAsyncEnumerable), 2173nameof(StreamingHub.CounterAsyncEnumerableAsync), 2174nameof(StreamingHub.CounterAsyncEnumerableImpl), 2175nameof(StreamingHub.AsyncEnumerableIsPreferredOverChannelReader), 3183var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 3190await client.SendHubMessageAsync(new StreamInvocationMessage("1", nameof(StreamingHub.BlockingStream), Array.Empty<object>())).DefaultTimeout(); 3192var completion = await client.InvokeAsync(nameof(StreamingHub.NonStream)).DefaultTimeout(); 3218var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 3226var messages = await client.StreamAsync(nameof(StreamingHub.ThrowStream)); 3232var hubActivator = serviceProvider.GetService<IHubActivator<StreamingHub>>() as CustomHubActivator<StreamingHub>; 3253var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 3261var messages = await client.StreamAsync(nameof(StreamingHub.NullStream)); 3267var hubActivator = serviceProvider.GetService<IHubActivator<StreamingHub>>() as CustomHubActivator<StreamingHub>; 3288var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 3296await client.SendHubMessageAsync(new StreamInvocationMessage("123", nameof(StreamingHub.BlockingStream), Array.Empty<object>())).DefaultTimeout(); 3298await client.SendHubMessageAsync(new StreamInvocationMessage("123", nameof(StreamingHub.BlockingStream), Array.Empty<object>())).DefaultTimeout(); 3303var hubActivator = serviceProvider.GetService<IHubActivator<StreamingHub>>() as CustomHubActivator<StreamingHub>; 4409HubConnectionHandler<StreamingHub> connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 4421var messagePromise = client.StreamAsync(nameof(StreamingHub.StreamEcho), new[] { streamId }, Array.Empty<object>()).DefaultTimeout(); 4452[InlineData(nameof(StreamingHub.DerivedParameterInterfaceAsyncEnumerable))] 4453[InlineData(nameof(StreamingHub.DerivedParameterBaseClassAsyncEnumerable))] 4454[InlineData(nameof(StreamingHub.DerivedParameterInterfaceAsyncEnumerableWithCancellation))] 4455[InlineData(nameof(StreamingHub.DerivedParameterBaseClassAsyncEnumerableWithCancellation))] 4460var argument = new StreamingHub.DerivedParameterTestObject { Value = "test" }; 4470SerializationBinder = StreamingHub.DerivedParameterKnownTypesBinder.Instance 4477var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>();