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