1 files changed, 4 insertions, 3 deletions
diff --git a/lib/PublicInbox/EOFpipe.pm b/lib/PublicInbox/EOFpipe.pm
index 3474874f..77b699a2 100644
--- a/lib/PublicInbox/EOFpipe.pm
+++ b/lib/PublicInbox/EOFpipe.pm
@@ -7,8 +7,8 @@ use parent qw(PublicInbox::DS);
  use PublicInbox::Syscall qw(EPOLLIN EPOLLONESHOT $F_SETPIPE_SZ);
  
  sub new {
-        my (undef, $rd, $cb) = @_;
-        my $self = bless { cb => $cb }, __PACKAGE__;
+        my (undef, $rd, @cb_args) = @_;
+        my $self = bless { cb_args => \@cb_args }, __PACKAGE__;
          # 4096: page size
          fcntl($rd, $F_SETPIPE_SZ, 4096) if $F_SETPIPE_SZ;
          $self->SUPER::new($rd, EPOLLIN|EPOLLONESHOT);
@@ -17,7 +17,8 @@ sub new {
  sub event_step {
          my ($self) = @_;
          if ($self->do_read(my $buf, 1) == 0) { # auto-closed
-                $self->{cb}->();
+                my ($cb, @args) = @{delete $self->{cb_args}};
+                $cb->(@args);
          }
  }