FindProvidersAsync respects cancelation is request not sent yet

ipfs · Nov 27, 2024 · da0117e · da0117e
1 parent 1cefd53
commit da0117e
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/routing/providerquerymanager/providerquerymanager.go b/routing/providerquerymanager/providerquerymanager.go
@@ -186,6 +186,10 @@ func (pqm *ProviderQueryManager) FindProvidersAsync(sessionCtx context.Context,
 		close(ch)
 		span.End()
 		return ch
+	case <-sessionCtx.Done():
+		ch := make(chan peer.AddrInfo)
+		close(ch)
+		return ch
 	}
 
 	// DO NOT select on sessionCtx. We only want to abort here if we're