- $fh->write($$bref);
- unless ($http->{closed}) { # Danga::Socket sets this
- if ($http->{write_buf_size}) {
- $self->watch_read(0);
- $http->write(restart_read_cb($self));
- }
- # stay in watch_read, but let other clients
- # get some work done, too.
+ $fh->write($buf); # may call $http->close
+ if ($http->{sock}) { # !closed
+ $self->requeue;
+ # let other clients get some work done, too