From c4b4a2e4cb5100e5f107949a160507417f47af44 Mon Sep 17 00:00:00 2001 From: ahmed Date: Sat, 23 Aug 2025 14:53:27 +0300 Subject: [PATCH] PV --- Esiur/Data/DataSerializer.cs | 2 +- Esiur/Net/IIP/DistributedConnectionProtocol.cs | 5 ++--- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/Esiur/Data/DataSerializer.cs b/Esiur/Data/DataSerializer.cs index 55f3479..636edc3 100644 --- a/Esiur/Data/DataSerializer.cs +++ b/Esiur/Data/DataSerializer.cs @@ -256,7 +256,7 @@ public static class DataSerializer rt.AddRange(Codec.Compose(pv.Value, connection)); } - return (TransmissionTypeIdentifier.List, rt.ToArray()); + return (TransmissionTypeIdentifier.RawData, rt.ToArray()); } public static (TransmissionTypeIdentifier, byte[]) TypedMapComposer(object value, Type keyType, Type valueType, DistributedConnection connection) diff --git a/Esiur/Net/IIP/DistributedConnectionProtocol.cs b/Esiur/Net/IIP/DistributedConnectionProtocol.cs index b5d4f67..0c42b02 100644 --- a/Esiur/Net/IIP/DistributedConnectionProtocol.cs +++ b/Esiur/Net/IIP/DistributedConnectionProtocol.cs @@ -542,7 +542,7 @@ partial class DistributedConnection r.Instance.Age, r.Instance.Link, r.Instance.Hops, - dr._Serialize()); + dr._Serialize(), this); } else { @@ -552,8 +552,7 @@ partial class DistributedConnection r.Instance.Age, r.Instance.Link, r.Instance.Hops, - r.Instance.Serialize()); - + r.Instance.Serialize(), this); } // subscribe