@@ -57,7 +57,6 @@ func (s *ProtocolData) workSend() {
//log.Println("sender closed")
t.Stop()
s.cancel()
- close(s.receiver)
}()
closed := false
lastSended := time.Now()
@@ -114,6 +113,7 @@ func (s *ProtocolData) workReceive() {
for {
select {
case <-s.ctx.Done():
+ close(s.receiver)
return
default:
packageID := []byte{0}