File tree Expand file tree Collapse file tree 1 file changed +0
-13
lines changed Expand file tree Collapse file tree 1 file changed +0
-13
lines changed Original file line number Diff line number Diff line change @@ -214,19 +214,6 @@ func (c *Connection) shutdown() {
214
214
c .waitGroup .Wait ()
215
215
// Close consumer error channel to signify connection shutdown
216
216
close (c .errorChan )
217
- // We can only close a channel once, so we have to jump through a few hoops
218
- select {
219
- // The channel is either closed or has an item pending
220
- case _ , ok := <- c .handshakeFinishedChan :
221
- // We successfully retrieved an item
222
- // This will probably never happen, but it doesn't hurt to cover this case
223
- if ok {
224
- close (c .handshakeFinishedChan )
225
- }
226
- // The channel is open and has no pending items
227
- default :
228
- close (c .handshakeFinishedChan )
229
- }
230
217
}
231
218
232
219
// setupConnection establishes the muxer, configures and starts the handshake process, and initializes
You can’t perform that action at this time.
0 commit comments