lib/PublicInbox/LEI.pm | 2 +-

diff --git a/lib/PublicInbox/LEI.pm b/lib/PublicInbox/LEI.pm
index 1e5b04cac3bdf5bb896daf1184852fe214e84b70..fdd9f8c86231cb95a6c3e6b4d7a87c5753b791b8 100644
--- a/lib/PublicInbox/LEI.pm
+++ b/lib/PublicInbox/LEI.pm
@@ -973,7 +973,7 @@ 	close(delete $self->{1}) if $self->{1}; # may reap_compress
 	if (my $sto = delete $self->{sto}) {
 		$sto->ipc_do('done');
 	}
-	$self->close if $self->{sock}; # PublicInbox::DS::close
+	$self->close if $self->{-event_init_done}; # PublicInbox::DS::close
 }
 
 # for long-running results