X-Git-Url: http://www.git.stargrave.org/?p=public-inbox.git;a=blobdiff_plain;f=lib%2FPublicInbox%2FPOP3.pm;h=741b5e58a90949854fdcf4331d2e3ad8e89bcfdf;hp=fcea4bb9d154ae4901b2c8fdc678d2d7481f1cb8;hb=a5e39d0e4e2d9b7ad937e8dd9af726d96eec6126;hpb=0f432191082f889c4296351e356c4abaf8cc7a28 diff --git a/lib/PublicInbox/POP3.pm b/lib/PublicInbox/POP3.pm index fcea4bb9..741b5e58 100644 --- a/lib/PublicInbox/POP3.pm +++ b/lib/PublicInbox/POP3.pm @@ -55,22 +55,6 @@ sub out ($$;@) { printf { $self->{pop3d}->{out} } $fmt."\n", @args; } -sub requeue_once ($) { - my ($self) = @_; - # COMPRESS users all share the same DEFLATE context. - # Flush it here to ensure clients don't see - # each other's data - $self->zflush; - - # no recursion, schedule another call ASAP, - # but only after all pending writes are done. - # autovivify wbuf: - my $new_size = push(@{$self->{wbuf}}, \&long_step); - - # wbuf may be populated by $cb, no need to rearm if so: - $self->requeue if $new_size == 1; -} - sub long_step { my ($self) = @_; # wbuf is unset or empty, here; {long} may add to it