r.writeQueue doesn't have to be closed.
This commit is contained in:
@@ -125,9 +125,6 @@ func NewRelay(ctx context.Context, url string, opts RelayOptions) *Relay {
|
|||||||
if r.closedNotify != nil {
|
if r.closedNotify != nil {
|
||||||
close(r.closedNotify)
|
close(r.closedNotify)
|
||||||
}
|
}
|
||||||
if r.writeQueue != nil {
|
|
||||||
close(r.writeQueue)
|
|
||||||
}
|
|
||||||
r.conn = nil
|
r.conn = nil
|
||||||
r.closeMutex.Unlock()
|
r.closeMutex.Unlock()
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user