intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 36 insertions, 0 deletions

diff --git a/library/cpp/messagebus/message_ptr_and_header.h b/library/cpp/messagebus/message_ptr_and_header.h
new file mode 100644
index 0000000000..9b4e2fd270
--- /dev/null
+++ b/library/cpp/messagebus/message_ptr_and_header.h
@@ -0,0 +1,36 @@
+#pragma once
+
+#include "message.h"
+#include "nondestroying_holder.h"
+
+#include <util/generic/noncopyable.h>
+#include <util/generic/utility.h>
+
+namespace NBus {
+    namespace NPrivate {
+        struct TBusMessagePtrAndHeader : TNonCopyable {
+            TNonDestroyingHolder<TBusMessage> MessagePtr;
+            TBusHeader Header;
+            ui32 LocalFlags;
+
+            TBusMessagePtrAndHeader()
+                : LocalFlags()
+            {
+            }
+
+            explicit TBusMessagePtrAndHeader(TBusMessage* messagePtr)
+                : MessagePtr(messagePtr)
+                , Header(*MessagePtr->GetHeader())
+                , LocalFlags(MessagePtr->LocalFlags)
+            {
+            }
+
+            void Swap(TBusMessagePtrAndHeader& that) {
+                DoSwap(MessagePtr, that.MessagePtr);
+                DoSwap(Header, that.Header);
+                DoSwap(LocalFlags, that.LocalFlags);
+            }
+        };
+
+    }
+}