view release on metacpan or  search on metacpan

lib/AnyEvent/STOMP/Client.pm  view on Meta::CPAN

570
571
572
573
574
575
576
577
578
579
580
581
582
583
584
585
586
587
588
589
590
    return;
}
 
$self->{handle}->unshift_read(
    regex => qr<\r?\n\r?\n>,
    cb => sub {
        my ($handle, $header_string) = @_;
        my $header_hashref = header_string2hash($header_string);
        my $args;
 
        # The headers of the CONNECTED frame are not en-/decoded
        # for backwards compatibility with STOMP 1.0
        unless ($command eq 'CONNECTED') {
            $header_hashref = decode_header($header_hashref);
        }
 
        if ($command =~ m/MESSAGE|ERROR/) {
            if (defined $header_hashref->{'content-length'}) {
                $args->{chunk} = $header_hashref->{'content-length'};
            }
            else {