aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/core/event.cpp
diff options
context:
space:
mode:
authoralexvru <alexvru@ydb.tech>2023-01-18 20:52:56 +0300
committeralexvru <alexvru@ydb.tech>2023-01-18 20:52:56 +0300
commit165a931108b2403c481db9430596b2ebef8c5391 (patch)
tree61c85dafdfa5a4bca0222a627d153d9c5c76c118 /library/cpp/actors/core/event.cpp
parent0d3b35526e4872d4609ba51cb38b46cc588aac71 (diff)
downloadydb-165a931108b2403c481db9430596b2ebef8c5391.tar.gz
Support interface part for ExternalDataChannel feature
Diffstat (limited to 'library/cpp/actors/core/event.cpp')
-rw-r--r--library/cpp/actors/core/event.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/library/cpp/actors/core/event.cpp b/library/cpp/actors/core/event.cpp
index 33f8ce2aaf..6a5230f825 100644
--- a/library/cpp/actors/core/event.cpp
+++ b/library/cpp/actors/core/event.cpp
@@ -17,7 +17,7 @@ namespace NActors {
if (Event) {
TAllocChunkSerializer serializer;
Event->SerializeToArcadiaStream(&serializer);
- auto chainBuf = serializer.Release(Event->IsExtendedFormat());
+ auto chainBuf = serializer.Release(Event->CreateSerializationInfo());
Event.Reset();
return chainBuf;
}
@@ -25,12 +25,13 @@ namespace NActors {
}
TIntrusivePtr<TEventSerializedData> IEventHandle::GetChainBuffer() {
- if (Buffer)
+ if (Buffer) {
return Buffer;
+ }
if (Event) {
TAllocChunkSerializer serializer;
Event->SerializeToArcadiaStream(&serializer);
- Buffer = serializer.Release(Event->IsExtendedFormat());
+ Buffer = serializer.Release(Event->CreateSerializationInfo());
return Buffer;
}
return new TEventSerializedData;