Skip to content

Commit cc67ae5

Browse files
committed
Include Deserialize in the receive activity
1 parent 9232135 commit cc67ae5

File tree

1 file changed

+19
-19
lines changed

1 file changed

+19
-19
lines changed

src/NATS.Client.Core/NatsMsg.cs

Lines changed: 19 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -369,25 +369,6 @@ public static NatsMsg<T> Build(
369369

370370
headers?.SetReadOnly();
371371

372-
T? data;
373-
if (headers?.Error == null)
374-
{
375-
try
376-
{
377-
data = serializer.Deserialize(payloadBuffer);
378-
}
379-
catch (Exception e)
380-
{
381-
headers ??= new NatsHeaders();
382-
headers.Error = new NatsDeserializeException(payloadBuffer.ToArray(), e);
383-
data = default;
384-
}
385-
}
386-
else
387-
{
388-
data = default;
389-
}
390-
391372
var size = subject.Length
392373
+ (replyTo?.Length ?? 0)
393374
+ (headersBuffer?.Length ?? 0)
@@ -418,6 +399,25 @@ public static NatsMsg<T> Build(
418399
}
419400
}
420401

402+
T? data;
403+
if (headers?.Error == null)
404+
{
405+
try
406+
{
407+
data = serializer.Deserialize(payloadBuffer);
408+
}
409+
catch (Exception e)
410+
{
411+
headers ??= new NatsHeaders();
412+
headers.Error = new NatsDeserializeException(payloadBuffer.ToArray(), e);
413+
data = default;
414+
}
415+
}
416+
else
417+
{
418+
data = default;
419+
}
420+
421421
return new NatsMsg<T>(subject, replyTo, (int)size, headers, data, connection, flags);
422422
}
423423

0 commit comments

Comments
 (0)