diff options
-rwxr-xr-x | server.pl | 7 |
1 files changed, 5 insertions, 2 deletions
@@ -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; |