Function keepReading

test/clientconn_state_transition_test.go:55–57

Keep reading until something causes the connection to die (EOF, server closed, etc). Useful as a tool for mindlessly keeping the connection healthy, since the client will error if things like client prefaces are not accepted in a timely fashion.

(conn net.Conn)

// healthy, since the client will error if things like client prefaces are not
// accepted in a timely fashion.
func keepReading(conn net.Conn) {
	io.Copy(io.Discard, conn)
}

type funcConnectivityStateSubscriber struct {
	onMsg func(connectivity.State)