8 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");