lib/PublicInbox/DS.pm | 7 +------ diff --git a/lib/PublicInbox/DS.pm b/lib/PublicInbox/DS.pm index ed04feb5c9e0d699feb0a4b05252aa29b8faa1aa..26c5251b5046951ca958650a929586e820909414 100644 --- a/lib/PublicInbox/DS.pm +++ b/lib/PublicInbox/DS.pm @@ -571,7 +571,7 @@ } # since connection has stuff to write, it should now be # interested in pending writes: $self->{wbuf_off} += $written; - $self->on_incomplete_write; + $self->watch_write(1); return 0; } elsif ($written == $to_write) { $self->{wbuf_off} = 0; @@ -588,11 +588,6 @@ undef $bref; next WRITE; } } -} - -sub on_incomplete_write { - my PublicInbox::DS $self = shift; - $self->watch_write(1); } =head2 C<< $obj->watch_read( $boolean ) >>