Add poller_t::wait

tests/poller.cpp

@@ -178,6 +178,19 @@ TEST_CASE("poller remove registered non empty", "[poller]")
 
 const std::string hi_str = "Hi";
 
+
+TEST_CASE("poller wait", "[poller]")
+{
+    common_server_client_setup s;
+    CHECK_NOTHROW(s.client.send(zmq::message_t{hi_str}, zmq::send_flags::none));
+    zmq::poller_t<int> poller;
+    int i = 42;
+    CHECK_NOTHROW(poller.add(s.server, zmq::event_flags::pollin, &i));
+    auto event = poller.wait();
+    CHECK(s.server == event.socket);
+    CHECK(&i == event.user_data);
+}
+
 TEST_CASE("poller poll basic", "[poller]")
 {
     common_server_client_setup s;

zmq.hpp

@@ -2762,6 +2762,18 @@ template<typename T = no_user_data> class poller_t
         }
     }
 
+    event_type wait(std::chrono::milliseconds timeout = std::chrono::milliseconds{
+                      -1})
+    {
+        event_type event;
+        int rc = zmq_poller_wait(poller_ptr.get(),
+                                 reinterpret_cast<zmq_poller_event_t *>(&event),
+                                 static_cast<long>(timeout.count()));
+        if (rc == -1)
+            throw error_t();
+        return event;
+    }
+
     template<typename Sequence>
     size_t wait_all(Sequence &poller_events, const std::chrono::milliseconds timeout)
     {