| … | … | ||
|---|---|---|---|
| 241 | 241 | ||
| 242 | $self->{_activity} = AnyEvent->now; | 242 | $self->{_activity} = AnyEvent->now; |
| 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 | |||
| 247 | $self->start_read | ||
| 248 | if $self->{on_read} || @{ $self->{_queue} }; | ||
| 246 | 249 | ||
| 247 | $self | 250 | $self |
| 248 | } | 251 | } |
| 249 | 252 | ||
| 250 | sub _shutdown { | 253 | sub _shutdown { |
| – | Removed lines |
| + | Added lines |
| < | Changed lines |
| > | Changed lines |