From a08049ee0fe81619002a0cabdb173e4e0e0967d1 Mon Sep 17 00:00:00 2001
From: Pedro Melo <melo@simplicidade.org>
Date: Thu, 23 Oct 2014 07:08:41 +0100
Subject: [PATCH] Add ready() to ::Client

Allow clients to update the ready count dynamically

Signed-off-by: Pedro Melo <melo@simplicidade.org>
---
 lib/AnyEvent/NSQ/Client.pm | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/lib/AnyEvent/NSQ/Client.pm b/lib/AnyEvent/NSQ/Client.pm
index 19075d2..8fb3d09 100644
--- a/lib/AnyEvent/NSQ/Client.pm
+++ b/lib/AnyEvent/NSQ/Client.pm
@@ -47,6 +47,14 @@ sub publish {
   return $conn->publish($topic, @data);
 }
 
+sub ready {
+  my ($self, $ready_count) = @_;
+
+  $_->{conn}->ready($ready_count) for values %{ $self->{nsqd_conns} };
+
+  return;
+}
+
 
 #### Argument parsing