fix leaking channel when closing connection
This commit is contained in:
@@ -218,6 +218,7 @@ func closeRPCWithTimeout(log Logger, remote rpc.RPCRequester, timeout time.Durat
|
|||||||
ch := make(chan error)
|
ch := make(chan error)
|
||||||
go func() {
|
go func() {
|
||||||
ch <- remote.CloseRequest(rpc.CloseRequest{goodbye})
|
ch <- remote.CloseRequest(rpc.CloseRequest{goodbye})
|
||||||
|
close(ch)
|
||||||
}()
|
}()
|
||||||
|
|
||||||
var err error
|
var err error
|
||||||
|
|||||||
Reference in New Issue
Block a user