intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 32 insertions, 0 deletions

diff --git a/library/cpp/messagebus/remote_server_connection.h b/library/cpp/messagebus/remote_server_connection.h
new file mode 100644
index 0000000000..63d7f20646
--- /dev/null
+++ b/library/cpp/messagebus/remote_server_connection.h
@@ -0,0 +1,32 @@
+#pragma once
+
+#include "session_impl.h"
+
+#include <util/generic/object_counter.h>
+
+namespace NBus {
+    namespace NPrivate {
+        class TRemoteServerConnection: public TRemoteConnection {
+            friend struct TBusSessionImpl;
+            friend class TRemoteServerSession;
+
+            TObjectCounter<TRemoteServerConnection> ObjectCounter;
+
+        public:
+            TRemoteServerConnection(TRemoteServerSessionPtr session, ui64 id, TNetAddr addr);
+
+            void Init(SOCKET socket, TInstant now);
+
+            inline TRemoteServerSession* GetSession();
+
+            void HandleEvent(SOCKET socket, void* cookie) override;
+
+            bool NeedInterruptRead() override;
+
+            void MessageSent(TArrayRef<TBusMessagePtrAndHeader> messages) override;
+
+            void ReaderProcessMessageUnknownVersion(TArrayRef<const char> dataRef) override;
+        };
+
+    }
+}