10 references to StreamAsChannelAsync
ClientSample (1)
UploadSample.cs (1)
95var outputs = await connection.StreamAsChannelAsync<string>("StreamEcho", channel.Reader);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (7)
HubConnectionTests.cs (7)
769var channel = await connection.StreamAsChannelAsync<int>("Stream", 5).DefaultTimeout(); 800var channel = await connection.StreamAsChannelAsync<string>("StreamEcho", channelWriter.Reader).DefaultTimeout(); 848var channel = await connection.StreamAsChannelAsync<string>("StreamEcho", stream).DefaultTimeout(); 896var channel = await connection.StreamAsChannelAsync<int>("StreamEchoInt", stream, cts.Token).DefaultTimeout(); 979var channel = await connection.StreamAsChannelAsync<int>("Stream", 1000, cts.Token).DefaultTimeout(); 1021await Assert.ThrowsAnyAsync<OperationCanceledException>(() => connection.StreamAsChannelAsync<int>("Stream", 5, cts.Token).DefaultTimeout()); 1245var channel = await connection.StreamAsChannelAsync<int>("Stream", "xyz");
Microsoft.AspNetCore.SignalR.Tests (2)
NativeAotTests.cs (2)
80var echoResponseReader = await connection.StreamAsChannelAsync<string>(nameof(AsyncMethodHub.StreamEcho), channel.Reader); 100var returnChannelValueTypeReader = await connection.StreamAsChannelAsync<char>(nameof(AsyncMethodHub.ReturnChannelValueType), "Hello");