[EN-7314] Implement the DXPublisher: DXPublisher::publishEventsImpl

dxFeed · Aug 21, 2023 · 3fe0948 · 3fe0948
1 parent 99e755e
commit 3fe0948
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 6 deletions.
diff --git a/include/dxfeed_graal_cpp_api/api/DXPublisher.hpp b/include/dxfeed_graal_cpp_api/api/DXPublisher.hpp
@@ -34,8 +34,6 @@ struct DXFCPP_EXPORT DXPublisher : SharedEntity {
     JavaObjectHandler<DXPublisher> handler_;
 
     static std::shared_ptr<DXPublisher> create(void *feedHandle) noexcept;
-
-    //TODO: implement
     void publishEventsImpl(void *graalEventsList) const noexcept;
 
   protected:

diff --git a/src/api/DXPublisher.cpp b/src/api/DXPublisher.cpp
@@ -9,11 +9,11 @@
 #include <string>
 #include <utility>
 
+#include "dxfeed_graal_cpp_api/api/DXPublisher.hpp"
 #include <fmt/chrono.h>
 #include <fmt/format.h>
 #include <fmt/ostream.h>
 #include <fmt/std.h>
-#include "dxfeed_graal_cpp_api/api/DXPublisher.hpp"
 
 namespace dxfcpp {
 
@@ -45,9 +45,13 @@ std::string DXPublisher::toString() const noexcept {
     return fmt::format("DXPublisher{{{}}}", handler_.toString());
 }
 
-//TODO: implement
 void DXPublisher::publishEventsImpl(void *graalEventsList) const noexcept {
-
+    runIsolatedOrElse(
+        [handler = bit_cast<dxfg_publisher_t *>(handler_.get()), graalEventsList](auto threadHandle) {
+            return dxfg_DXPublisher_publishEvents(dxfcpp::bit_cast<graal_isolatethread_t *>(threadHandle), handler,
+                                                  bit_cast<dxfg_event_type_list *>(graalEventsList)) == 0;
+        },
+        false);
 }
 
-}
+} // namespace dxfcpp