* should return immediately. Responses returned after shutdown will not be transmitted: their
   * socket connections have already been closed.
   */
  public open override fun close() {}

    val partAbc = parts.nextPart()!!
    val partMno = parts.nextPart()!!

    assertFailsWith<IllegalStateException> {
      partAbc.body.request(20)
    }.also { expected ->
      assertThat(expected).hasMessage("closed")
    }

    assertThat(partMno.body.readUtf8()).isEqualTo("mnop")
    assertThat(parts.nextPart()).isNull()
  }

  @Test fun `cannot read part after calling close`() {
    val multipart =
      """

            // if (endpoint != null) {
            //     endpoint.close();
            // }
        } finally {
            state = RdmaConnectionState.CLOSED;
        }

        log.debug("DiSNI RDMA connection closed");
    }

   * Puts each 16-bit code unit from the {@link CharSequence} into this sink.
   *
   * <p><b>Warning:</b> This method will produce different output than most other languages do when
   * running on the equivalent input. For cross-language compatibility, use {@link #putString},
   * usually with a charset of UTF-8. For other use cases, use {@code putUnencodedChars}.
   *
   * @since 15.0 (since 11.0 as putString(CharSequence))
   */

But if you have custom headers that you want a client in a browser to be able to see, you need to add them to your CORS configurations ([CORS (Cross-Origin Resource Sharing)](cors.md){.internal-link target=_blank}) using the parameter `expose_headers` documented in <a href="https://www.starlette.dev/middleware/#corsmiddleware" class="external-link" target="_blank">Starlette's CORS docs</a>.

                final boolean timeout = ex instanceof SocketTimeoutException || msg != null && msg.equals("Read timed out");
                final boolean closed = msg != null && msg.equals("Socket closed");

                if (closed) {
                    log.trace("Remote closed connection");
                } else if (timeout) {
                    log.debug("socket timeout in non peek state", ex);
                } else {

    // only use by reread()
    @TempDir
    Path projectRoot;

    /**
     * Provides file system configurations for testing both Windows and Unix path behaviors.
     * This allows us to test cross-platform path handling on any development machine.
     */
    static Stream<Arguments> fileSystemConfigurations() {
        return Stream.of(
                Arguments.of("Unix", Configuration.unix(), "/"),

g/en-US/docs/Web/HTTP/Headers" class="external-link" target="_blank">usando el prefijo `X-`</a>.

Pero si tienes custom headers que deseas que un cliente en un navegador pueda ver, necesitas añadirlos a tus configuraciones de CORS ([CORS (Cross-Origin Resource Sharing)](cors.md){.internal-link target=_blank}) usando el parámetro `expose_headers` documentado en <a href="https://www.starlette.dev/middleware/#corsmiddleware" class="external-link" target="_blank">la documentación de CORS de Starlette</a>....

        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

    /**
     * Gets a byte array from an {@link InputStream}.
     * <p>
     * The input stream is not closed.
     * </p>
     *
     * @param is the input stream (must not be {@literal null})
     * @return the byte array
     */
    public static final byte[] getBytes(final InputStream is) {

  }

  private companion object {
    /**
     * Enqueued on shutdown to release threads waiting on [dispatch]. Note that this response
     * isn't transmitted because the connection is closed before this response is returned.
     */
    private val DEAD_LETTER = MockResponse(code = HTTP_UNAVAILABLE)

    private val logger = Logger.getLogger(QueueDispatcher::class.java.name)
  }