| … | |
… | |
| 79 | |
79 | |
| 80 | Set the callback to be called when an end-of-file condition is detected, |
80 | Set the callback to be called when an end-of-file condition is detected, |
| 81 | i.e. in the case of a socket, when the other side has closed the |
81 | i.e. in the case of a socket, when the other side has closed the |
| 82 | connection cleanly. |
82 | connection cleanly. |
| 83 | |
83 | |
| 84 | While not mandatory, it is highly recommended to set an eof callback, |
84 | While not mandatory, it is I<highly> recommended to set an eof callback, |
| 85 | otherwise you might end up with a closed socket while you are still |
85 | otherwise you might end up with a closed socket while you are still |
| 86 | waiting for data. |
86 | waiting for data. |
|
|
87 | |
|
|
88 | If an EOF condition has been detected but no C<on_eof> callback has been |
|
|
89 | set, then a fatal error will be raised with C<$!> set to <0>. |
| 87 | |
90 | |
| 88 | =item on_error => $cb->($handle, $fatal) |
91 | =item on_error => $cb->($handle, $fatal) |
| 89 | |
92 | |
| 90 | This is the error callback, which is called when, well, some error |
93 | This is the error callback, which is called when, well, some error |
| 91 | occured, such as not being able to resolve the hostname, failure to |
94 | occured, such as not being able to resolve the hostname, failure to |
| … | |
… | |
| 766 | delete $self->{_rw}; |
769 | delete $self->{_rw}; |
| 767 | last; |
770 | last; |
| 768 | } |
771 | } |
| 769 | } |
772 | } |
| 770 | |
773 | |
|
|
774 | if ($self->{_eof}) { |
|
|
775 | if ($self->{on_eof}) { |
| 771 | $self->{on_eof}($self) |
776 | $self->{on_eof}($self) |
| 772 | if $self->{_eof} && $self->{on_eof}; |
777 | } else { |
|
|
778 | $self->_error (0, 1); |
|
|
779 | } |
|
|
780 | } |
| 773 | |
781 | |
| 774 | # may need to restart read watcher |
782 | # may need to restart read watcher |
| 775 | unless ($self->{_rw}) { |
783 | unless ($self->{_rw}) { |
| 776 | $self->start_read |
784 | $self->start_read |
| 777 | if $self->{on_read} || @{ $self->{_queue} }; |
785 | if $self->{on_read} || @{ $self->{_queue} }; |
