diff --git a/p2p/helpers.go b/p2p/helpers.go index c8d3b21c..f2dcddb6 100644 --- a/p2p/helpers.go +++ b/p2p/helpers.go @@ -105,7 +105,7 @@ func sendMessage( } if err == nil { - if closeErr := stream.Close(); closeErr != nil { + if closeErr := stream.CloseRead(); closeErr != nil { log.Errorw("closing stream", "err", closeErr) } } else {