7 references to StreamTracker
Microsoft.AspNetCore.SignalR.Core (7)
Internal\DefaultHubDispatcher.cs (6)
253
if (connection.
StreamTracker
.TryComplete(completionMessage))
309
connection.
StreamTracker
.TryComplete(message);
317
if (!connection.
StreamTracker
.TryProcessItem(message, out var processTask))
576
connection.
StreamTracker
.TryComplete(streamId, streamOwner.Value);
851
arguments[parameterPointer] = connection.
StreamTracker
.AddStream(hubMethodInvocationMessage.StreamIds[streamPointer],
852
itemType, descriptor.OriginalParameterTypes[parameterPointer], streamOwner ??= connection.
StreamTracker
.GetNextStreamOwner());
Internal\HubConnectionBinder.cs (1)
38
return _connection.
StreamTracker
.GetStreamItemType(streamId);