diff --git a/p2p/host/hostv2/hostv2.go b/p2p/host/hostv2/hostv2.go index ada6e4479..83a3bc883 100644 --- a/p2p/host/hostv2/hostv2.go +++ b/p2p/host/hostv2/hostv2.go @@ -83,7 +83,7 @@ func (host *HostV2) SendMessage(p p2p.Peer, message []byte) error { } // Create a buffered stream so that read and writes are non blocking. - w := bufio.NewWriter(bufio.NewWriter(s)) + w := bufio.NewWriter(s) // Create a thread to read and write data. go writeData(w, message)