lru.Add("key1", 1)
	lru.Add("key1", 2)

	if value, ok := lru.Get("key1"); !ok || value != 2 {
		t.Errorf("Expected value to be updated to 2, got %v", value)
	}
}

func TestLRU_Add_NewKey_AddsEntry(t *testing.T) {
	lru := lru.NewLRU[string, int](10, nil, time.Hour)
	lru.Add("key1", 1)

	if value, ok := lru.Get("key1"); !ok || value != 1 {
		t.Errorf("Expected key1 to be added with value 1, got %v", value)

        assertEquals(Path.of("src/main/resources").toString(), resources.get(0).getDirectory());
        assertEquals(Path.of("src/main/resources2").toString(), resources.get(1).getDirectory());
        assertEquals(Path.of("src/main/resources3").toString(), resources.get(2).getDirectory());

        // Modify the middle resource
        resources.get(1).addInclude("*.properties");

    assertMapsEqual(expected, map);
    assertEquals(expected.get("a"), map.get("a"));
    assertEquals(expected.containsKey("a"), map.containsKey("a"));
    assertEquals(expected.get("b"), map.get("b"));
    assertEquals(expected.containsKey("b"), map.containsKey("b"));
    assertEquals(expected.get("c"), map.get("c"));
    assertEquals(expected.containsKey("c"), map.containsKey("c"));
  }

                    .get());
            options.addOption(Option.builder(NON_RECURSIVE)
                    .longOpt("non-recursive")
                    .desc(
                            "Do not recurse into sub-projects. When used together with -pl, do not recurse into sub-projects of selected aggregators")
                    .get());
            options.addOption(Option.builder(UPDATE_SNAPSHOTS)

        assertNotNull(map);
        assertEquals("", map.get(FieldNames.TEXT)); // Empty string for empty map
        assertEquals(0L, map.get(FieldNames.QUERY_FREQ));
        assertEquals(0L, map.get(FieldNames.DOC_FREQ));
        assertEquals(1.0f, map.get(FieldNames.USER_BOOST));
        assertNotNull(map.get(FieldNames.READING_PREFIX + "0"));
        assertNotNull(map.get(FieldNames.FIELDS));
        assertNotNull(map.get(FieldNames.TAGS));

    assertThat(loadCount.get()).isEqualTo(2);
    assertThat(reloadCount.get()).isEqualTo(1);
    assertThat(loadAllCount.get()).isEqualTo(2);

    executor.runNext();
    assertThat(loadCount.get()).isEqualTo(2);
    assertThat(reloadCount.get()).isEqualTo(2);
    assertThat(loadAllCount.get()).isEqualTo(2);
  }

  enum CollectStrategy {
    /** Get one accumulator and accumulate the elements into it sequentially. */
    SEQUENTIAL {
      @Override
      final <T extends @Nullable Object, A extends @Nullable Object, R extends @Nullable Object>
          A result(Collector<T, A, R> collector, Iterable<T> inputs) {
        A accum = collector.supplier().get();
        for (T input : inputs) {

        assertEquals(4, result.getFailures().size());
        assertTrue(result.getFailures().get(0) instanceof Exception);
        assertTrue(result.getFailures().get(1) instanceof RuntimeException);
        assertTrue(result.getFailures().get(2) instanceof IllegalStateException);
        assertTrue(result.getFailures().get(3) instanceof NullPointerException);
    }

    response = client.get("/items/", headers=[("save_data", "true")])
    assert response.status_code == 200
    assert response.json() == {
        "host": "testserver",
        "save_data": True,
        "if_modified_since": None,
        "traceparent": None,
        "x_tag": [],
    }


def test_header_param_model_invalid(client: TestClient):
    response = client.get("/items/")

app = FastAPI()


class Model(BaseModel):
    param: str = Field(alias="param_alias")


@app.get("/query")
async def query_model(data: Model = Query()):
    return {"param": data.param}


@app.get("/header")
async def header_model(data: Model = Header()):
    return {"param": data.param}


@app.get("/cookie")
async def cookie_model(data: Model = Cookie()):
    return {"param": data.param}