From 883b34503d2fc69825912f0033dea44046af7685 Mon Sep 17 00:00:00 2001 From: ArthurSonzogni Date: Mon, 25 May 2020 02:36:32 +0200 Subject: [PATCH] Add Receiver->HasPending() --- include/ftxui/component/receiver.hpp | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/include/ftxui/component/receiver.hpp b/include/ftxui/component/receiver.hpp index e1a1c2cc..86874fe6 100644 --- a/include/ftxui/component/receiver.hpp +++ b/include/ftxui/component/receiver.hpp @@ -21,8 +21,8 @@ namespace ftxui { // --------------- // // auto receiver = MakeReceiver(); -// auto sender_1= receiver.MakeSender(); -// auto sender_2 = receiver.MakeSender(); +// auto sender_1= receiver->MakeSender(); +// auto sender_2 = receiver->MakeSender(); // // Then move the senders elsewhere, potentially in a different thread. // @@ -83,6 +83,11 @@ class ReceiverImpl { return false; } + bool HasPending() { + std::unique_lock lock(mutex_); + return !queue_.empty(); + } + private: friend class SenderImpl;