fix:close ask/dealstatus stream (#710)

hunjixin · web-flow · commit f88ff91ec671 · 2022-05-11T11:40:37.000+02:00
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 {

Original file line number	Diff line number	Diff line change
`@@ -221,6 +221,7 @@ func (c *Client) GetAsk(ctx context.Context, info storagemarket.StorageProviderI`
`221`	`221`	`if err != nil {`
`222`	`222`	`return nil, xerrors.Errorf("failed to open stream to miner: %w", err)`
`223`	`223`	`}`
	`224`	`+ defer s.Close() //nolint`
`224`	`225`
`225`	`226`	`request := network.AskRequest{Miner: info.Address}`
`226`	`227`	`if err := s.WriteAskRequest(request); err != nil {`
`@@ -269,6 +270,7 @@ func (c *Client) GetProviderDealState(ctx context.Context, proposalCid cid.Cid)`
`269`	`270`	`if err != nil {`
`270`	`271`	`return nil, xerrors.Errorf("failed to open stream to miner: %w", err)`
`271`	`272`	`}`
	`273`	`+ defer s.Close() //nolint`
`272`	`274`
`273`	`275`	`buf, err := cborutil.Dump(&deal.ProposalCid)`
`274`	`276`	`if err != nil {`