assertFalse(future.isDone());
    assertFalse(future.isCancelled());
    assertThrows(TimeoutException.class, () -> future.get(0, MILLISECONDS));
    nested.set("foo");
    assertTrue(future.isDone());
    assertFalse(future.isCancelled());
    assertThat(future.get()).isEqualTo("foo");
  }

  private static class Foo {}

  private static class FooChild extends Foo {}

    throw IllegalStateException("Expected Android API level 21+ but was ${Build.VERSION.SDK_INT}")
  }

  actual val isAndroid: Boolean
    get() = true

  var applicationContext: Context?
    get() = (Platform.get() as? ContextAwarePlatform)?.applicationContext
    set(value) {
      (Platform.get() as? ContextAwarePlatform)?.applicationContext = value
    }

      return null;
    } else {
      Range<K> range = ranges.get(index);
      return range.contains(key) ? immutableEntry(range, values.get(index)) : null;
    }
  }

  @Override
  public Range<K> span() {
    if (ranges.isEmpty()) {
      throw new NoSuchElementException();
    }
    Range<K> firstRange = ranges.get(0);
    Range<K> lastRange = ranges.get(ranges.size() - 1);

        fess_doc = {
            "url": doc.get("url", ""),
            "title": doc.get("title", ""),
            "content": doc.get("content", ""),
            "mimetype": doc.get("mimetype", "text/html"),
            "filetype": doc.get("filetype", "html"),
            "created": doc.get("@timestamp", ""),
            "timestamp": doc.get("@timestamp", ""),
            # Add custom fields as needed
        }

    implementation(localGroovy())
    testImplementation(testLibs.findLibrary("spock").get())
    testImplementation(testLibs.findLibrary("bytebuddy").get())
    testImplementation(testLibs.findLibrary("objenesis").get())

    testRuntimeOnly(testLibs.findLibrary("junitPlatform").get())
}

tasks.withType<GroovyCompile>().configureEach {
    groovyOptions.apply {
        encoding = "utf-8"

from inline_snapshot import Is, snapshot

app = FastAPI()


@app.get("/required-str/{p}")
async def read_required_str(p: Annotated[str, Path()]):
    return {"p": p}


@app.get("/required-alias/{p_alias}")
async def read_required_alias(p: Annotated[str, Path(alias="p_alias")]):
    return {"p": p}


@app.get("/required-validation-alias/{p_val_alias}")
def read_required_validation_alias(

        assertTrue(result1.isPresent());
        assertTrue(result2.isPresent());
        assertTrue(result3.isPresent());
        assertEquals(Locale.GERMANY, result1.get());
        assertEquals(Locale.GERMANY, result2.get());
        assertEquals(Locale.GERMANY, result3.get());
    }

    // Helper method to create mock RequestManager
    private RequestManager createMockRequestManager(final String paramValue) {

    void defaultConstructor_initialState() {
        // Arrange & Act
        SecurityBlob blob = new SecurityBlob();

        // Assert
        assertNotNull(blob.get(), "get() should never return null for default instance");
        assertEquals(0, blob.get().length, "Internal array should be empty");
        assertEquals(0, blob.length(), "length() should be 0 for empty");

    name: str
    description: str = None  # type: ignore
    price: float


@app.get("/product")
async def create_item(product: Product):
    return product


client = TestClient(app)


def test_get_with_body():
    body = {"name": "Foo", "description": "Some description", "price": 5.5}
    response = client.request("GET", "/product", json=body)
    assert response.json() == body


def test_openapi_schema():

func (sys *BucketVersioningSys) PrefixSuspended(bucket, prefix string) bool {
	vc, err := sys.Get(bucket)
	if err != nil {
		logger.CriticalIf(GlobalContext, err)
	}

	return vc.PrefixSuspended(prefix)
}

// Get returns stored bucket policy
func (sys *BucketVersioningSys) Get(bucket string) (*versioning.Versioning, error) {
	if bucket == minioMetaBucket || strings.HasPrefix(bucket, minioMetaBucket) {