From 85df9f31c18aa012782e7d7db931cba334fded83 Mon Sep 17 00:00:00 2001 From: anutosh491 Date: Wed, 27 Mar 2024 15:36:01 +0530 Subject: [PATCH] registering the listeners --- include/xeus-zmq/xclient_zmq.hpp | 2 ++ src/xclient_zmq.cpp | 10 ++++++++++ 2 files changed, 12 insertions(+) diff --git a/include/xeus-zmq/xclient_zmq.hpp b/include/xeus-zmq/xclient_zmq.hpp index 9eed125..42fa5ad 100644 --- a/include/xeus-zmq/xclient_zmq.hpp +++ b/include/xeus-zmq/xclient_zmq.hpp @@ -42,10 +42,12 @@ namespace xeus void register_shell_listener(const listener& l); void register_control_listener(const listener& l); void register_iopub_listener(const listener& l); + void register_heartbeat_listener(const listener& l); void notify_shell_listener(xmessage msg); void notify_control_listener(xmessage msg); void notify_iopub_listener(xmessage msg); + void notify_heartbeat_listener(xmessage msg); std::size_t iopub_queue_size() const; std::optional pop_iopub_message(); diff --git a/src/xclient_zmq.cpp b/src/xclient_zmq.cpp index ad9dc54..6dc2d9c 100644 --- a/src/xclient_zmq.cpp +++ b/src/xclient_zmq.cpp @@ -58,6 +58,11 @@ namespace xeus p_client_impl->register_iopub_listener(l); } + void xclient_zmq::register_heartbeat_listener(const listener& l) + { + p_client_impl->register_heartbeat_listener(l); + } + void xclient_zmq::notify_shell_listener(xmessage msg) { p_client_impl->notify_shell_listener(std::move(msg)); @@ -73,6 +78,11 @@ namespace xeus p_client_impl->notify_iopub_listener(std::move(msg)); } + void xclient_zmq::notify_heartbeat_listener(xmessage msg) + { + p_client_impl->notify_heartbeat_listener(std::move(msg)); + } + std::size_t xclient_zmq::iopub_queue_size() const { return p_client_impl->iopub_queue_size();