if ($r) {
$fh->write($$bref);
unless ($http->{closed}) { # PublicInbox::DS sets this
- if ($http->{write_buf_size}) {
+ if (scalar @{$http->{wbuf}}) {
$self->watch_read(0);
$http->write(restart_read_cb($self));
}
}
sub event_read { $_[0]->{cb}->(@_) }
-sub event_hup { $_[0]->{cb}->(@_) }
-sub event_err { $_[0]->{cb}->(@_) }
sub close {
my $self = shift;