kubernetes/vendor/go.etcd.io/etcd/client/pkg/v3/transport/timeout_listener.go

// NewTimeoutListener returns a listener that listens on the given address.
// If read/write on the accepted connection blocks longer than its time limit,
// it will return timeout error.
func NewTimeoutListener(addr string, scheme string, tlsinfo *TLSInfo, readTimeout, writeTimeout time.Duration) (net.Listener, error) { … }

type rwTimeoutListener …

func (rwln *rwTimeoutListener) Accept() (net.Conn, error) { … }