/
vshmidt
/
masstransit
Обзор
Документация
Войти
/
vshmidt
/
masstransit
Код
Запросы
0
Задачи
Вики
Пакеты
0
Релизы
0
Аналитика
Безопасность
develop
src/MassTransit.SignalR/Utils/SerializedHubMessageExtensions.cs
33 строки
1 KB
Denys Kozhevnikov
SignalR refactoring, Use ConfigureEndpoints(context), Scoped Publish/Request, AddMassTransitBackplane - obsolete, use AddSignalRHub, dropped MessageData support
13 май 2020, 17:04
13 май 2020, 17:04
3ded01b
Код
Авторство
О чём код?
namespace MassTransit.SignalR.Utils { using System; using System.Collections.Generic; using System.Linq; using Microsoft.AspNetCore.SignalR; using Microsoft.AspNetCore.SignalR.Protocol; public static class SerializedHubMessageExtensions { public static SerializedHubMessage ToSerializedHubMessage(this IReadOnlyDictionary<string, byte[]> protocolMessages) { return new SerializedHubMessage(protocolMessages.Select(message => new SerializedMessage(message.Key, message.Value)).ToList()); } public static IReadOnlyDictionary<string, byte[]> ToProtocolDictionary(this IEnumerable<IHubProtocol> protocols, string methodName, object[] args) { var serializedMessageHub = new SerializedHubMessage(new InvocationMessage(methodName, args)); var messages = new Dictionary<string, byte[]>(); foreach (var protocol in protocols) { ReadOnlyMemory<byte> serialized = serializedMessageHub.GetSerializedMessage(protocol); messages.Add(protocol.Name, serialized.ToArray()); } return messages; } } }