// When
            InputStream is1 = mockResource.openInputStream();
            InputStream is2 = mockResource.openInputStream(1);
            InputStream is3 = mockResource.openInputStream(1, 2, 3);

            // Then
            assertNotNull(is1, "Default input stream should not be null");
            assertNotNull(is2, "Input stream with sharing should not be null");

    @Test
    @DisplayName("getServerEncryptionKey returns expected bytes")
    void serverEncryptionKey_variants() {
        byte[] key = new byte[] { 1, 2, 3 };
        when(transport.getServerEncryptionKey()).thenReturn(key);
        assertArrayEquals(key, transport.getServerEncryptionKey());
        verify(transport).getServerEncryptionKey();

        // Empty array

      getResponse(
        Request(
          url = server.url("/"),
          body = "123".toRequestBody(null),
        ),
      ),
    )
    val request1 = server.takeRequest()
    assertThat(request1.exchangeIndex).isEqualTo(0)
    val request2 = server.takeRequest()
    assertThat(request2.body?.utf8()).isEqualTo("123")
    assertThat(request2.exchangeIndex).isEqualTo(0)
  }

  @Test

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`。

        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);

  }

  /**
   * Returns a string containing the supplied {@code char} values separated by {@code separator}.
   * For example, {@code join("-", '1', '2', '3')} returns the string {@code "1-2-3"}.
   *
   * @param separator the text that should appear between consecutive values in the resulting string
   *     (but not at the start or end)

Якщо ви оголосите `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 }

      }
    }
    return flip(max);
  }

  /**
   * Returns a string containing the supplied unsigned {@code int} values separated by {@code
   * separator}. For example, {@code join("-", 1, 2, 3)} returns the string {@code "1-2-3"}.
   *
   * @param separator the text that should appear between consecutive values in the resulting string
   *     (but not at the start or end)

 * Stopwatch stopwatch = Stopwatch.createStarted();
 * doSomething();
 * stopwatch.stop(); // optional
 *
 * Duration duration = stopwatch.elapsed();
 *
 * log.info("time: " + stopwatch); // formatted string like "12.3 ms"
 * }
 *
 * <p>The state-changing methods are not idempotent; it is an error to start or stop a stopwatch
 * that is already in the desired state.
 *