@Test
    @DisplayName("Test reset with key and lastName")
    void testResetWithKeyAndLastName() {
        // Reset with parameters should not throw exception
        assertDoesNotThrow(() -> transaction.reset(123, "testName"));

        // Transaction should be ready for reuse
        assertTrue(transaction.hasMoreElements());
    }

    @Test
    @DisplayName("Test hasMoreElements")
    void testHasMoreElements() {

Se você declarar `response_class=StreamingResponse` na sua função de operação de rota, você pode usar `yield` para enviar cada bloco de dados em sequência.

{* ../../docs_src/stream_data/tutorial001_py310.py ln[1:23] hl[20,23] *}

O FastAPI entregará cada bloco de dados para `StreamingResponse` como está, não tentará convertê-lo para JSON nem nada semelhante.

## 使用 `yield` 的 `StreamingResponse` { #a-streamingresponse-with-yield }

如果你在*路径操作函数*中声明 `response_class=StreamingResponse`，你就可以使用 `yield` 依次发送每个数据块。

{* ../../docs_src/stream_data/tutorial001_py310.py ln[1:23] hl[20,23] *}

FastAPI 会将每个数据块原样交给 `StreamingResponse`，不会尝试将其转换为 JSON 或做类似处理。

### 非 async 的*路径操作函数* { #non-async-path-operation-functions }

你也可以使用常规的 `def` 函数（不带 `async`），并以相同方式使用 `yield`。

## Code includes with unknown attributes { #code-includes-with-unknown-attributes }

{* ../../docs_src/python_types/tutorial001_py310.py unknown[123] *}

## Some more code includes to test fixing { #some-more-code-includes-to-test-fixing }

{* ../../docs_src/dependencies/tutorial013_an_py310.py ln[19:21] *}

        // CSV with numbers and mixed data types - quoted fields keep quotes
        value = "123,\"Product Name\",45.67,\"Description with, comma\"";
        result = KuromojiCSVUtil.parse(value);
        assertEquals(4, result.length);
        assertEquals("123", result[0]);
        assertEquals("Product Name", result[1]);
        assertEquals("45.67", result[2]);

  private static final String ALMOST_TOO_LONG = Strings.repeat("aaaaa.", 40) + "1234567890.c";

  private static final ImmutableSet<String> VALID_NAME =
      ImmutableSet.of(
          // keep-sorted start
          "123.cn",
          "8server.shop",
          "a" + DELTA + "b.com",
          "abc.a23",
          "biz.com.ua",
          "f--1.com",
          "f--o",
          "f-_-o.cOM",
          "f11-1.com",
          "fOo",

    - [Other notable changes](#other-notable-changes-2)
- [v1.2.4](#v124)
  - [Downloads for v1.2.4](#downloads-for-v124)
  - [Changes since v1.2.3](#changes-since-v123)
    - [Other notable changes](#other-notable-changes-3)
- [v1.2.3](#v123)
  - [Downloads for v1.2.3](#downloads-for-v123)
  - [Changes since v1.2.2](#changes-since-v122)
    - [Action Required](#action-required)
    - [Other notable changes](#other-notable-changes-4)

     */
    @Test
    public void test_getAnchorSet_withUnsupportedType() {
        FessCrawlerThread crawlerThread = new FessCrawlerThread();

        Integer unsupportedType = 123;

        Set<RequestData> result = crawlerThread.getAnchorSet(unsupportedType);
        assertNull(result, "getAnchorSet should return null for unsupported type");
    }

    /**

        buildHeader(buf, headerStart, NtStatus.NT_STATUS_SUCCESS, 0x0001, 0xCAFEBABECAFEF00DL);

        int bodyStart = headerStart + Smb2Constants.SMB2_HEADER_LENGTH;
        byte[] blob = new byte[] { 1, 2, 3 };
        int secBufOffset = Smb2Constants.SMB2_HEADER_LENGTH + 8;
        int sessionFlags = 0; // not guest/null
        buildSessionSetupBody(buf, headerStart, bodyStart, sessionFlags, secBufOffset, blob);

        });
    }

    @Test
    void testEncodeDecode() {
        // Setup SMB with some data
        smb.command = ServerMessageBlock.SMB_COM_ECHO;
        smb.mid = 123;
        smb.pid = 456;
        smb.tid = 789;
        smb.uid = 101;
        smb.flags2 = ServerMessageBlock.FLAGS2_UNICODE;
        smb.useUnicode = true;

        byte[] params = { 0x01, 0x02, 0x03, 0x04 };