$self->SUPER::recv_and_run(@args);
}
-sub _sto_atexit { # dwaitpid callback
- my ($args, $pid) = @_;
- my $self = $args->[0];
+sub _sto_atexit { # awaitpid cb
+ my ($pid) = @_;
warn "lei/store PID:$pid died \$?=$?\n" if $?;
}
lei => $lei,
-err_wr => $w,
to_close => [ $r ],
- });
- $self->wq_wait_async(\&_sto_atexit); # outlives $lei
+ }, \&_sto_atexit);
require PublicInbox::LeiStoreErr;
PublicInbox::LeiStoreErr->new($r, $lei);
}