diff --git a/metadapta.go b/metadapta.go index aa941e3..20074b3 100644 --- a/metadapta.go +++ b/metadapta.go @@ -109,6 +109,7 @@ func (this *a) sendMessageSafe(trans int64, method uint16, data []byte) error { func (this *a) receive() { defer func() { this.underlying.Close() + close(this.transChan) this.transLock.Lock() defer this.transLock.Unlock() for _, trans := range this.transMap {