diff --git a/chain/exchange/client.go b/chain/exchange/client.go
index 290840801..db39628be 100644
--- a/chain/exchange/client.go
+++ b/chain/exchange/client.go
@@ -430,7 +430,9 @@ func (c *client) sendRequestToPeer(ctx context.Context, peer peer.ID, req *Reque
 	}
 	_ = stream.SetWriteDeadline(time.Time{}) // clear deadline // FIXME: Needs
 	//  its own API (https://github.com/libp2p/go-libp2p/core/issues/162).
-	stream.CloseWrite()
+	if err := stream.CloseWrite(); err != nil {
+		log.Warnw("CloseWrite err", "error", err)
+	}
 
 	// Read response.
 	var res Response
diff --git a/node/hello/hello.go b/node/hello/hello.go
index e688902d5..e05b8a482 100644
--- a/node/hello/hello.go
+++ b/node/hello/hello.go
@@ -158,7 +158,9 @@ func (hs *Service) SayHello(ctx context.Context, pid peer.ID) error {
 	if err := cborutil.WriteCborRPC(s, hmsg); err != nil {
 		return xerrors.Errorf("writing rpc to peer: %w", err)
 	}
-	s.CloseWrite()
+	if err := s.CloseWrite(); err != nil {
+		log.Warnw("CloseWrite err", "error", err)
+	}
 
 	go func() {
 		defer s.Close() //nolint:errcheck