19 references to StreamAsyncCore
Microsoft.AspNetCore.SignalR.Client.Core (11)
HubConnectionExtensions.StreamAsync.cs (11)
29
return hubConnection.
StreamAsyncCore
<TResult>(methodName, Array.Empty<object>(), cancellationToken);
46
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1 }, cancellationToken);
64
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2 }, cancellationToken);
83
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2, arg3 }, cancellationToken);
103
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2, arg3, arg4 }, cancellationToken);
124
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2, arg3, arg4, arg5 }, cancellationToken);
146
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2, arg3, arg4, arg5, arg6 }, cancellationToken);
169
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2, arg3, arg4, arg5, arg6, arg7 }, cancellationToken);
193
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8 }, cancellationToken);
218
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9 }, cancellationToken);
244
return hubConnection.
StreamAsyncCore
<TResult>(methodName, new[] { arg1, arg2, arg3, arg4, arg5, arg6, arg7, arg8, arg9, arg10 }, cancellationToken);
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (2)
HubConnectionTests.cs (1)
457
var asyncEnumerable = connection.
StreamAsyncCore
<int>("Stream", new object[] { streamTo });
HubConnectionTests.Tracing.cs (1)
266
var asyncEnumerable = connection.
StreamAsyncCore
<int>("Stream", new object[] { streamTo });
Microsoft.AspNetCore.SignalR.Client.Tests (6)
HubConnectionTests.cs (3)
856
mockConnection.Setup(c => c.
StreamAsyncCore
<object>(It.IsAny<string>(), It.IsAny<object[]>(), It.IsAny<CancellationToken>())).Returns(() => It.IsAny<IAsyncEnumerable<object>>());
868
_ = hubConnection.
StreamAsyncCore
<int>("stream2", Array.Empty<object>(), default);
877
mockConnection.Verify(c => c.
StreamAsyncCore
<int>("stream2", Array.Empty<object>(), It.IsAny<CancellationToken>()), Times.Once);
HubServerProxyGeneratorTests.cs (3)
195
.Setup(x => x.
StreamAsyncCore
<int>(
282
.Setup(x => x.
StreamAsyncCore
<int>(
288
.Setup(x => x.
StreamAsyncCore
<int>(