INNER CODE UNIT · Go

silentUpstream

docker/compose · relay/main_test.go:85

func silentUpstream(t *testing.T) net.Listener {
	t.Helper()
	upstream, err := net.Listen("tcp", "127.0.0.1:0")
	if err != nil {
		t.Fatal(err)
	}
	t.Cleanup(func() { _ = upstream.Close() })
	go func() {
		conn, err := upstream.Accept()
		if err != nil {
			return
		}
		defer func() { _ = conn.Close() }()
		_, _ = io.Copy(io.Discard, conn) // read the FIN, never answer, never close
		time.Sleep(5 * time.Second)
	}()
	return upstream
}

View source record →