diff --git a/comm.go b/comm.go
index 5d05e09..430e6a6 100644
--- a/comm.go
+++ b/comm.go
@@ -70,7 +70,7 @@ func (p *PubSub) handleSendingMessages(ctx context.Context, s inet.Stream, outgo
 		return bufw.Flush()
 	}
 
-	defer s.Close()
+	defer inet.FullClose(s)
 	for {
 		select {
 		case rpc, ok := <-outgoing: