Release stream when conn ends

2016-05-02 14:03:58 +02:00 · 2016-05-02 14:03:58 +02:00 · 18069d377c
parent 36bf645199
commit 18069d377c
1 changed files with 2 additions and 0 deletions
--- a/transport/hub/udp_server.go
+++ b/transport/hub/udp_server.go
@ -66,6 +66,8 @@ func (this *UDPServer) handleConnection(destString string, inboundRay ray.Inboun
 		callback(source, data)
 	}
 	this.Lock()
+	inboundRay.InboundInput().Release()
+	inboundRay.InboundOutput().Release()
 	delete(this.conns, destString)
 	this.Unlock()
 }