fix:close ask/dealstatus stream (#710)

filecoin-project · May 11, 2022 · f88ff91 · f88ff91
1 parent a088d71
commit f88ff91
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/storagemarket/impl/client.go b/storagemarket/impl/client.go
@@ -221,6 +221,7 @@ func (c *Client) GetAsk(ctx context.Context, info storagemarket.StorageProviderI
 	if err != nil {
 		return nil, xerrors.Errorf("failed to open stream to miner: %w", err)
 	}
+	defer s.Close()  //nolint
 
 	request := network.AskRequest{Miner: info.Address}
 	if err := s.WriteAskRequest(request); err != nil {
@@ -269,6 +270,7 @@ func (c *Client) GetProviderDealState(ctx context.Context, proposalCid cid.Cid)
 	if err != nil {
 		return nil, xerrors.Errorf("failed to open stream to miner: %w", err)
 	}
+	defer s.Close()  //nolint
 
 	buf, err := cborutil.Dump(&deal.ProposalCid)
 	if err != nil {