| 1 | package AnyEvent::Handle; |
1 | package AnyEvent::Handle; |
| 2 | |
2 | |
| 3 | no warnings; |
3 | no warnings; |
| 4 | use strict; |
4 | use strict qw(subs vars); |
| 5 | |
5 | |
| 6 | use AnyEvent (); |
6 | use AnyEvent (); |
| 7 | use AnyEvent::Util qw(WSAEWOULDBLOCK); |
7 | use AnyEvent::Util qw(WSAEWOULDBLOCK); |
| 8 | use Scalar::Util (); |
8 | use Scalar::Util (); |
| 9 | use Carp (); |
9 | use Carp (); |
| … | |
… | |
| 730 | ) { |
730 | ) { |
| 731 | return $self->_error (&Errno::ENOSPC, 1); |
731 | return $self->_error (&Errno::ENOSPC, 1); |
| 732 | } |
732 | } |
| 733 | |
733 | |
| 734 | while () { |
734 | while () { |
| 735 | no strict 'refs'; |
|
|
| 736 | |
|
|
| 737 | my $len = length $self->{rbuf}; |
735 | my $len = length $self->{rbuf}; |
| 738 | |
736 | |
| 739 | if (my $cb = shift @{ $self->{_queue} }) { |
737 | if (my $cb = shift @{ $self->{_queue} }) { |
| 740 | unless ($cb->($self)) { |
738 | unless ($cb->($self)) { |
| 741 | if ($self->{_eof}) { |
739 | if ($self->{_eof}) { |
