From d714e5b4f2c857e987949a0a0932a3ff10aa49ad Mon Sep 17 00:00:00 2001
From: hunjixin <1084400399@qq.com>
Date: Wed, 11 May 2022 13:23:58 +0800
Subject: [PATCH] fix:close ask/dealstatus stream

---
 storagemarket/impl/client.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/storagemarket/impl/client.go b/storagemarket/impl/client.go
index 0c46c4c2..b221c27a 100644
--- 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 {