1 files changed, 8 insertions, 0 deletions
diff --git a/cpp/src/IceStorm/SubscriberPool.cpp b/cpp/src/IceStorm/SubscriberPool.cpp
index 26d99dee299..4f1e568583c 100644
--- a/cpp/src/IceStorm/SubscriberPool.cpp
+++ b/cpp/src/IceStorm/SubscriberPool.cpp
@@ -206,6 +206,14 @@ SubscriberPool::flush(list<SubscriberPtr>& subscribers)
 }
 
 void
+SubscriberPool::flush(const SubscriberPtr& subscriber)
+{
+    Lock sync(*this);
+    _pending.push_back(subscriber);
+    notify();
+}
+
+void
 SubscriberPool::add(const SubscriberPtr& subscriber)
 {
     Lock sync(*this);