68 references to StreamingHub
Microsoft.AspNetCore.SignalR.Tests (68)
HubConnectionHandlerTests.Activity.cs (21)
194var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 203AssertHubMethodActivity<StreamingHub>(connectActivity, mockHttpRequestActivity, nameof(StreamingHub.OnConnectedAsync), linkedActivity: null, activityName: SignalRServerActivitySource.OnConnected); 205_ = await client.StreamAsync(nameof(StreamingHub.CounterChannel), 3).DefaultTimeout(); 208AssertHubMethodActivity<StreamingHub>(invocation1Activity, parent: null, nameof(StreamingHub.CounterChannel), mockHttpRequestActivity); 213AssertHubMethodActivity<StreamingHub>(invocation2Activity, parent: null, "RenamedCounterChannel", mockHttpRequestActivity); 221AssertHubMethodActivity<StreamingHub>(disconnectedActivity, mockHttpRequestActivity, nameof(StreamingHub.OnDisconnectedAsync), linkedActivity: null, activityName: SignalRServerActivitySource.OnDisconnected); 253var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 262AssertHubMethodActivity<StreamingHub>(connectActivity, mockHttpRequestActivity, nameof(StreamingHub.OnConnectedAsync), linkedActivity: null, activityName: SignalRServerActivitySource.OnConnected); 271_ = await client.StreamAsync(nameof(StreamingHub.CounterChannel), streamIds: null, headers: headers, 3).DefaultTimeout(); 274AssertHubMethodActivity<StreamingHub>(invocationActivity, parent: null, nameof(StreamingHub.CounterChannel), mockHttpRequestActivity); 288AssertHubMethodActivity<StreamingHub>(disconnectActivity, mockHttpRequestActivity, nameof(StreamingHub.OnDisconnectedAsync), linkedActivity: null, activityName: SignalRServerActivitySource.OnDisconnected); 425var connectionHandler = serviceProvider.GetService<HubConnectionHandler<StreamingHub>>(); 431_ = await client.StreamAsync(nameof(StreamingHub.ExceptionAsyncEnumerable)).DefaultTimeout(); 436AssertHubMethodActivity<StreamingHub>(activity, parent: null, 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>>();
NativeAotTests.cs (2)
242public StreamingHub.AsyncEnumerableImpl<string> CounterAsyncEnumerableImpl(int count) 244return new StreamingHub.AsyncEnumerableImpl<string>(CounterAsyncEnumerable(count));