val source = Buffer().writeUtf8("hello")
          return object : ForwardingSource(source) {
            @Throws(IOException::class)
            override fun close(): Unit = throw IOException("Broken!")
          }.buffer()
        }
      }
    assertThat(body.source().readUtf8()).isEqualTo("hello")
    body.close()
  }

  @Test
  fun unicodeText() {
    val text = "eile oli oliiviõli"

@router.route("/items/")
def read_items(request: Request):
    return JSONResponse({"hello": "world"})


app.include_router(router)

client = TestClient(app)


def test_sub_router():
    response = client.get("/items/")
    assert response.status_code == 200, response.text

            String originalString = "Hello World Test";
            byte[] allBytes = originalString.getBytes(StandardCharsets.UTF_16LE);
            int partialLength = "Hello World".getBytes(StandardCharsets.UTF_16LE).length;

            // When
            String result = Strings.fromUNIBytes(allBytes, 0, partialLength);

            // Then

# Code blocks { #code-blocks }

Some text

```python
# This is a sample Python code block
def hello_world():
    # Comment with indentation
    print("Hello, world!")  # Print greeting
```

Some more text

```toml
# This is a sample TOML code block
title = "TOML Example"  # Title of the document
```

And more text

```console
// Use the command "live" and pass the language code as a CLI argument

# Code blocks { #code-blocks }

Some text

```python
# This is a sample Python code block
def hello_world():
    # Comment with indentation
    print("Hello, world!")  # Print greeting
```

Some more text

```toml
# This is a sample TOML code block
title = "TOML Example"  # Title of the document
```

Extra code block

```
$ cd my_project
```

And more text

```console

		},
		// duplicate '$bucket' reject
		{

        .build(),
    )
    val webSocket: WebSocket = newWebSocket()
    clientListener.assertOpen()
    val server = serverListener.assertOpen()
    webSocket.send("Hello, WebSockets!")
    serverListener.assertTextMessage("Hello, WebSockets!")
    closeWebSockets(webSocket, server)
  }

  @Test
  fun binaryMessage() {
    webServer.enqueue(
      MockResponse
        .Builder()

      .build()

  fun executeAndCheckUpgrade(request: Request) {
    val socketHandler =
      MockSocketHandler()
        .apply {
          receiveRequest("client says hello\n")
          sendResponse("server says hello\n")
          receiveRequest("client says goodbye\n")
          sendResponse("server says goodbye\n")
          exhaustResponse()
          exhaustRequest()
        }

import pytest
from fastapi import FastAPI
from fastapi.testclient import TestClient

app = FastAPI()


@app.get("/a", responses={"hello": {"description": "Not a valid additional response"}})
async def a():
    pass  # pragma: no cover


openapi_schema = {
    "openapi": "3.1.0",
    "info": {"title": "FastAPI", "version": "0.1.0"},
    "paths": {
        "/a": {
            "get": {
                "responses": {

    }

    @Test
    public void test_buildFunctionScoreQuery_multiWordQuery() {
        QueryBuilder innerQuery = request.buildQuery("hello world", Collections.emptyList());
        QueryBuilder result = request.buildFunctionScoreQuery("hello world", innerQuery);

        assertNotNull(result);
        assertTrue(result instanceof FunctionScoreQueryBuilder);

        String queryString = result.toString();