Buffered or unbuffered? That is the question.

rtp/session.go

@@ -53,7 +53,7 @@ func NewSession(host string) (rs *Session, err error) {
 		return nil, err
 	}
 	rs = &Session{
-		C:    make(chan *Frame, 32),
+		C:    make(chan *Frame, 4),
 		E:    make(chan error, 1),
 		Sock: sock.(*net.UDPConn),
 		Header: Header{

sip/dialog.go

@@ -256,6 +256,8 @@ func (dls *dialogState) cleanup() {
 	if dls.sock != nil {
 		dls.sock.Close()
 		dls.sock = nil
+		_, _ = <-dls.sockMsgs
+		<-dls.sockErrs
 	}
 }
 

sip/receiver.go

@@ -1,7 +1,6 @@
 package sip
 
 import (
-	"github.com/jart/gosip/util"
 	"log"
 	"net"
 	"strconv"
@@ -13,10 +12,8 @@ func ReceiveMessages(contact *Addr, sock *net.UDPConn, c chan<- *Msg, e chan<- e
 	for {
 		amt, addr, err := sock.ReadFromUDP(buf)
 		if err != nil {
-			if !util.IsUseOfClosed(err) {
-				e <- err
-			}
-			return
+			e <- err
+			break
 		}
 		ts := time.Now()
 		packet := string(buf[0:amt])
@@ -36,6 +33,8 @@ func ReceiveMessages(contact *Addr, sock *net.UDPConn, c chan<- *Msg, e chan<- e
 		fixMessagesFromStrictRouters(contact, msg)
 		c <- msg
 	}
+	close(c)
+	close(e)
 }
 
 func addReceived(msg *Msg, addr *net.UDPAddr) {

sip/transport.go

@@ -48,8 +48,8 @@ func NewTransport(contact *Addr) (tp *Transport, err error) {
 	contact.Next = nil
 	contact.Uri.Port = uint16(addr.Port)
 	contact.Uri.Params["transport"] = "udp"
-	c := make(chan *Msg, 32)
-	e := make(chan error, 1)
+	c := make(chan *Msg)
+	e := make(chan error)
 	tp = &Transport{
 		C:       c,
 		E:       e,