1 implementation of IStreamConverter
Microsoft.AspNetCore.SignalR.Core (1)
StreamTracker.cs (1)
106
private sealed class ChannelConverter<T> :
IStreamConverter
9 references to IStreamConverter
Microsoft.AspNetCore.SignalR.Core (9)
StreamTracker.cs (9)
19
private readonly ConcurrentDictionary<string,
IStreamConverter
> _lookup = new ConcurrentDictionary<string,
IStreamConverter
>();
37
var
newConverter = (
IStreamConverter
)_buildConverterMethod.MakeGenericMethod(itemType).Invoke(null, _streamConverterArgs)!;
42
private bool TryGetConverter(string streamId, [NotNullWhen(true)] out
IStreamConverter
? converter)
54
if (TryGetConverter(message.InvocationId!, out
var
converter))
66
if (TryGetConverter(streamId, out
var
converter))
76
_lookup.TryRemove(message.InvocationId!, out
var
converter);
93
private static
IStreamConverter
BuildStream<T>(int streamBufferCapacity)