//
// TODO(bcmills): This should arguably be a server configuration parameter,
// not a hard-coded value.
var rstAvoidanceDelay = 500 * time.Millisecond

type closeWriter interface {
	CloseWrite() error
}

var _ closeWriter = (*net.TCPConn)(nil)

// closeWriteAndWait flushes any outstanding data and sends a FIN packet (if
// client is connected via TCP), signaling that we're done. We then

`TryRead` and `TryWrite` are still available for non-blocking reads and writes.

To signify the end of the stream, close the ring buffer from the writer side with `rb.CloseWriter()`

Either side can use `rb.CloseWithError(err error)` to signal an error and close the ring buffer. 
Any reads or writes will return the error on next call.

		{"(*Config).Clone", Method, 8},
		{"(*Config).DecryptTicket", Method, 21},
		{"(*Config).EncryptTicket", Method, 21},
		{"(*Config).SetSessionTicketKeys", Method, 5},
		{"(*Conn).Close", Method, 0},
		{"(*Conn).CloseWrite", Method, 8},
		{"(*Conn).ConnectionState", Method, 0},
		{"(*Conn).Handshake", Method, 0},
		{"(*Conn).HandshakeContext", Method, 17},
		{"(*Conn).LocalAddr", Method, 0},
		{"(*Conn).NetConn", Method, 18},

		if clientGone {
			// TODO: could we also get into this state if
			// the peer does a half close
			// (e.g. CloseWrite) because they're done
			// sending frames but they're still wanting
			// our open replies?  Investigate.
			// TODO: add CloseWrite to crypto/tls.Conn first
			// so we have a way to test this? I suppose
			// just for testing we could have a non-TLS mode.
			return false

// and always returns nil.
func (r *RingBuffer) CloseWithError(err error) {
	if err == nil {
		err = io.EOF
	}
	r.setErr(err, false)
}

// CloseWriter closes the writer.
// Reads will return any remaining bytes and io.EOF.
func (r *RingBuffer) CloseWriter() {
	r.setErr(io.EOF, false)
}

// Flush waits for the buffer to be empty and fully read.

			}
			if doSleep && writeRng.Intn(10) == 0 {
				time.Sleep(time.Duration(writeRng.Intn(maxSleep)))
			}
		}
		if err := rb.Flush(); err != nil {
			t.Fatalf("flush failed: %v", err)
		}
		rb.CloseWriter()
	}
	wg.Wait()
	if !errors.Is(readErr, io.EOF) {
		t.Fatalf("expect io.EOF but got %v", readErr)
	}
	if readBytes != wroteBytes {
		a, b := readBuf.Bytes(), wroteBuf.Bytes()

pkg net, method (*TCPAddr) Network() string
pkg net, method (*TCPAddr) String() string
pkg net, method (*TCPConn) Close() error
pkg net, method (*TCPConn) CloseRead() error
pkg net, method (*TCPConn) CloseWrite() error
pkg net, method (*TCPConn) File() (*os.File, error)
pkg net, method (*TCPConn) LocalAddr() Addr
pkg net, method (*TCPConn) Read([]uint8) (int, error)
pkg net, method (*TCPConn) ReadFrom(io.Reader) (int64, error)

pkg net, method (*UDPConn) WriteMsgUDP([]uint8, []uint8, *UDPAddr) (int, int, error)
pkg net, method (*UnixConn) CloseRead() error
pkg net, method (*UnixConn) CloseWrite() error
pkg net, type Dialer struct
pkg net, type Dialer struct, Deadline time.Time
pkg net, type Dialer struct, LocalAddr Addr
pkg net, type Dialer struct, Timeout time.Duration