diff options
author | alexvru <alexvru@ydb.tech> | 2023-01-18 20:52:56 +0300 |
---|---|---|
committer | alexvru <alexvru@ydb.tech> | 2023-01-18 20:52:56 +0300 |
commit | 165a931108b2403c481db9430596b2ebef8c5391 (patch) | |
tree | 61c85dafdfa5a4bca0222a627d153d9c5c76c118 /library/cpp/actors/core/event.cpp | |
parent | 0d3b35526e4872d4609ba51cb38b46cc588aac71 (diff) | |
download | ydb-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.cpp | 7 |
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; |