1 files changed, 39 insertions, 0 deletions
diff --git a/veslibrary/ves_cpplibrary/src/lib/transport/XBufferedTransport.h b/veslibrary/ves_cpplibrary/src/lib/transport/XBufferedTransport.h
new file mode 100755
index 0000000..af51f64
--- /dev/null
+++ b/veslibrary/ves_cpplibrary/src/lib/transport/XBufferedTransport.h
@@ -0,0 +1,39 @@
+#pragma once
+
+#include "XTransport.h"
+#include "XQueue.h"
+#include <future>
+#include <mutex>
+#include <condition_variable>
+
+namespace vagt
+{
+    namespace transport
+    {
+        class XBufferedTransport : public XTransport
+        {
+        public:
+            XBufferedTransport(std::shared_ptr<XTransport> transport, std::shared_ptr<vagt::queue::XQueue> queue);
+            virtual ~XBufferedTransport();
+
+            virtual XErrorCode start() override;
+            virtual XErrorCode stop() override;
+            virtual XErrorCode post(const std::string& event) override;
+
+            virtual void cancelPost() override;
+            virtual void allowPost() override;
+            virtual bool shouldCancelPost() override;
+
+        private:
+            void worker();
+
+            std::shared_ptr<XTransport> transport_;
+            std::shared_ptr<queue::XQueue> queue_;
+            std::future<void> future_;
+
+            std::condition_variable cond_;
+            std::mutex lock_;
+        };
+    }
+}
+