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 {