… | … | ||
---|---|---|---|
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 |