From 5142b3a15a17f467dee4584930f3d0c5ef862486 Mon Sep 17 00:00:00 2001
From: Pedro Melo <melo@simplicidade.org>
Date: Sun, 20 Jul 2014 22:12:38 +0100
Subject: [PATCH] Add disconnect() to Client, closes all connected conns

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

diff --git a/lib/AnyEvent/NSQ/Client.pm b/lib/AnyEvent/NSQ/Client.pm
index 6fd00ea..8448b1a 100644
--- a/lib/AnyEvent/NSQ/Client.pm
+++ b/lib/AnyEvent/NSQ/Client.pm
@@ -22,6 +22,12 @@ sub new {
   return $self;
 }
 
+sub disconnect {
+  my ($self, $cb) = @_;
+
+  $_->{conn}->disconnect($cb) for values %{ $self->{nsqd_conns} };
+}
+
 
 #### Argument parsing