X-Git-Url: http://dxcluster.net/gitweb/gitweb.cgi?a=blobdiff_plain;f=perl%2FAsyncMsg.pm;h=ff3b3bca07c01eae0c52afbc43a6cebfe08830c8;hb=511d83a615a5e65e85d7337c85280c2b6470a91b;hp=95c5e8f67c974d8eace5f0e5ba9b7fbf69ef42f1;hpb=af00b2713eb62cdee83a6bf184e2b410226f8be6;p=spider.git diff --git a/perl/AsyncMsg.pm b/perl/AsyncMsg.pm index 95c5e8f6..ff3b3bca 100644 --- a/perl/AsyncMsg.pm +++ b/perl/AsyncMsg.pm @@ -203,9 +203,11 @@ sub raw my %args = @_; my $handler = delete $args{handler} || \&handle_raw; + my $conn = $pkg->new($call, $handler); $conn->{prefix} = delete $args{prefix} if exists $args{prefix}; $conn->{prefix} ||= ''; + $conn->{on_disconnect} = delete $args{on_disc} || delete $args{on_disconnect}; $r = $conn->connect($host, $port, on_connect => &_on_raw_connect); return $r ? $conn : undef; }