server: Do not close socket before sending

1 files changed, 5 insertions, 2 deletions

diff --git a/server.pl b/server.pl
index 14804e7..4958fa4 100755
--- a/server.pl
+++ b/server.pl
@@ -53,8 +53,11 @@ tcp_server 'unix/', $stats_socket, sub {
 
     $h->push_write(Storable::freeze($stats) . "\n");
     $stats = { ham => 0, spam => 0, block => 0 };
-    $h->destroy;
-    undef $h;
+
+    $h->on_drain (sub {
+        $h->destroy;
+        undef $h;
+    });
 };
 
 AnyEvent->condvar->recv;