call Stream.CloseWrite right after writing

chain/exchange/client.go

@@ -430,6 +430,7 @@ 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()
 
 	// Read response.
 	var res Response

node/hello/hello.go

@@ -158,6 +158,7 @@ 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()
 
 	go func() {
 		defer s.Close() //nolint:errcheck