|
@@ -135,7 +135,7 @@ namespace InABox.Rpc
|
|
|
|
|
|
public void NotifyAll<TNotification>(TNotification notification) where TNotification : BaseObject
|
|
|
{
|
|
|
- var message = new RpcMessage(Guid.NewGuid(), "Notification", RpcNotification.Create(notification).WriteBinary(BinarySerializationSettings.Latest)));
|
|
|
+ var message = new RpcMessage(Guid.NewGuid(), "Notification", RpcNotification.Create(notification).WriteBinary(BinarySerializationSettings.Latest));
|
|
|
foreach (var connection in _sessions.Keys)
|
|
|
{
|
|
|
Send(connection, message);
|
|
@@ -144,7 +144,7 @@ namespace InABox.Rpc
|
|
|
|
|
|
public void NotifySession<TNotification>(Guid session, TNotification notification) where TNotification : BaseObject
|
|
|
{
|
|
|
- var message = new RpcMessage(Guid.NewGuid(), "Notification", RpcNotification.Create(notification).WriteBinary(BinarySerializationSettings.Latest)));
|
|
|
+ var message = new RpcMessage(Guid.NewGuid(), "Notification", RpcNotification.Create(notification).WriteBinary(BinarySerializationSettings.Latest));
|
|
|
|
|
|
var sessionConnection = _sessions.FirstOrDefault(x => x.Value.ID == session).Key;
|
|
|
if(sessionConnection is not null)
|