1 implementation of IStreamConverter
Microsoft.AspNetCore.SignalR.Core (1)
StreamTracker.cs (1)
98
private sealed class ChannelConverter<T> :
IStreamConverter
9 references to IStreamConverter
Microsoft.AspNetCore.SignalR.Core (9)
StreamTracker.cs (9)
17
private readonly ConcurrentDictionary<string,
IStreamConverter
> _lookup = new ConcurrentDictionary<string,
IStreamConverter
>();
29
var
newConverter = (
IStreamConverter
)_buildConverterMethod.MakeGenericMethod(itemType).Invoke(null, _streamConverterArgs)!;
34
private bool TryGetConverter(string streamId, [NotNullWhen(true)] out
IStreamConverter
? converter)
46
if (TryGetConverter(message.InvocationId!, out
var
converter))
58
if (TryGetConverter(streamId, out
var
converter))
68
_lookup.TryRemove(message.InvocationId!, out
var
converter);
85
private static
IStreamConverter
BuildStream<T>(int streamBufferCapacity)