()
| 54 | } |
| 55 | |
| 56 | func (c *closeOnCloseReader) Close() error { |
| 57 | c.mu.Lock() |
| 58 | defer c.mu.Unlock() |
| 59 | c.closed = true |
| 60 | return nil |
| 61 | } |
| 62 | |
| 63 | // deadUpstreamAddr returns a TCP address that is guaranteed to refuse |
| 64 | // connections: we bind a listener, note its address, close it immediately, |
no outgoing calls
no test coverage detected