change the signature of receiver method

houshuo · Apr 21, 2017 · 2ccb9b1 · 2ccb9b1
1 parent 0c875ad
commit 2ccb9b1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/sess.go b/sess.go
@@ -609,7 +609,7 @@ func (s *UDPSession) kcpInput(data []byte) {
 	}
 }
 
-func (s *UDPSession) receiver(ch chan []byte) {
+func (s *UDPSession) receiver(ch chan <- []byte) {
 	for {
 		data := xmitBuf.Get().([]byte)[:mtuLimit]
 		if n, _, err := s.conn.ReadFrom(data); err == nil && n >= s.headerSize+IKCP_OVERHEAD {
@@ -749,7 +749,7 @@ func (l *Listener) monitor() {
 	}
 }
 
-func (l *Listener) receiver(ch chan inPacket) {
+func (l *Listener) receiver(ch chan <- inPacket) {
 	for {
 		data := xmitBuf.Get().([]byte)[:mtuLimit]
 		if n, from, err := l.conn.ReadFrom(data); err == nil && n >= l.headerSize+IKCP_OVERHEAD {