Skip to content

Commit

Permalink
Addressed the reviews
Browse files Browse the repository at this point in the history
  • Loading branch information
anutosh491 committed Mar 26, 2024
1 parent d4135b5 commit 14f9877
Show file tree
Hide file tree
Showing 5 changed files with 8 additions and 8 deletions.
1 change: 1 addition & 0 deletions include/xeus-zmq/xclient_zmq.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -47,6 +47,7 @@ namespace xeus
void notify_control_listener(xmessage msg);
void notify_iopub_listener(xmessage msg);

std::size_t iopub_queue_size() const;
std::optional<xmessage> pop_iopub_message();
void connect();
void stop_channels();
Expand Down
5 changes: 5 additions & 0 deletions src/xclient_zmq.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -73,6 +73,11 @@ namespace xeus
p_client_impl->notify_iopub_listener(std::move(msg));
}

std::size_t xclient_zmq::iopub_queue_size() const
{
return p_client_impl->iopub_queue_size();
}

std::optional<xmessage> xclient_zmq::pop_iopub_message()
{
return p_client_impl->pop_iopub_message();
Expand Down
7 changes: 1 addition & 6 deletions src/xclient_zmq_impl.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -93,11 +93,6 @@ namespace xeus
m_iopub_listener = l;
}

xclient_messenger& xclient_zmq_impl::get_client_messenger()
{
return p_messenger;
}

void xclient_zmq_impl::connect()
{
p_messenger.connect();
Expand Down Expand Up @@ -171,7 +166,7 @@ namespace xeus
void xclient_zmq_impl::start()
{
start_iopub_thread();
// TODO
// TODO : Introduce a client, xheartbeat_client that runs on its own thread, m_heartbeat_thread.
}

void xclient_zmq_impl::start_iopub_thread()
Expand Down
1 change: 0 additions & 1 deletion src/xclient_zmq_impl.hpp
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,6 @@ namespace xeus
// TODO

// client messenger
xclient_messenger& get_client_messenger();
void connect();
void stop_channels();

Expand Down
2 changes: 1 addition & 1 deletion xeus-zmqConfig.cmake.in
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ set(CMAKE_MODULE_PATH "${CMAKE_CURRENT_LIST_DIR};${CMAKE_MODULE_PATH}")
@XEUS_ZMQ_CONFIG_CODE@

include(CMakeFindDependencyMacro)
find_dependency(nlohmann_json @nlohmann_json_REQUIRED_VERSION@ EXACT)
find_dependency(nlohmann_json @nlohmann_json_VERSION@ EXACT)
find_dependency(xeus @xeus_REQUIRED_VERSION@)

# On Unix platforms, ZeroMQ is built with autotools and pkg-config is
Expand Down

0 comments on commit 14f9877

Please sign in to comment.