| … | … | ||
|---|---|---|---|
| 243 | $self->_timeout; | 243 | $self->_timeout; |
| 244 | 244 | ||
| 245 | $self->on_drain (delete $self->{on_drain}) if $self->{on_drain}; | 245 | $self->on_drain (delete $self->{on_drain}) if $self->{on_drain}; |
| 246 | 246 | ||
| 247 | $self->start_read | 247 | $self->start_read |
| 248 | if $self->{on_read} || @{ $self->{_queue} }; | 248 | if $self->{on_read}; |
| 249 | 249 | ||
| 250 | $self | 250 | $self |
| 251 | } | 251 | } |
| 252 | 252 | ||
| 253 | sub _shutdown { | 253 | sub _shutdown { |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |