diff --git a/p2p/helpers.go b/p2p/helpers.go index 2e4df655..dc8cc1c5 100644 --- a/p2p/helpers.go +++ b/p2p/helpers.go @@ -103,7 +103,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 {