diff --git a/pkg/shreder/txparser.go b/pkg/shreder/txparser.go
index 726a800..a025676 100644
--- a/pkg/shreder/txparser.go
+++ b/pkg/shreder/txparser.go
@@ -72,11 +72,15 @@ func ParseTransactionForSubscribe(ctx context.Context, update *SubscribeUpdateTr
 	versioned, err := toVersionedTransaction(update)
 	if err != nil {
 		logger.Debug("txparser: failed to convert to versioned transaction", "error", err)
-		close(done)
+		if done != nil {
+			close(done)
+		}
 		return
 	}
 	ParseTransaction(ctx, versioned, loader, parsed)
-	close(done)
+	if done != nil {
+		close(done)
+	}
 }
 
 var VoteProgram = solana.MustPublicKeyFromBase58("Vote111111111111111111111111111111111111111")