try (final BufferedReader br = new BufferedReader(new InputStreamReader(new FileInputStream(tempFile)));
                    final BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(con.getOutputStream(), Constants.CHARSET_UTF_8))) {
                String line;
                while ((line = br.readLine()) != null) {
                    if (StringUtil.isNotBlank(line)) {

  override fun getLocalAddress(): InetAddress = delegate!!.localAddress

  override fun getLocalPort(): Int = delegate!!.localPort

  @Throws(IOException::class)
  override fun getOutputStream(): OutputStream = delegate!!.outputStream

  override fun getPort(): Int = delegate!!.port

  @Throws(SocketException::class)
  override fun getSoLinger(): Int = delegate!!.soLinger

        public int exitValue() {
            return exitValue;
        }

        @Override
        public void destroy() {
        }

        @Override
        public java.io.OutputStream getOutputStream() {
            return null;
        }

        @Override
        public java.io.InputStream getInputStream() {
            return new java.io.ByteArrayInputStream(new byte[0]);
        }

    synchronized(this) {
      if (executor.isShutdown) {
        socket.close()
        return
      }
    }
    val outputStream = socket.getOutputStream()
    val inputStream = socket.getInputStream()
    val reader = Http2Reader(inputStream.source().buffer(), client)
    val outFramesIterator: Iterator<OutFrame> = outFrames.iterator()

        public int exitValue() {
            return exitValue;
        }

        @Override
        public void destroy() {
        }

        @Override
        public java.io.OutputStream getOutputStream() {
            return null;
        }

        @Override
        public java.io.InputStream getInputStream() {
            return null;
        }

        @Override

            @Override
            public String getContentType() {
                return null;
            }

            @Override
            public jakarta.servlet.ServletOutputStream getOutputStream() throws IOException {
                return null;
            }

            @Override
            public java.io.PrintWriter getWriter() throws IOException {
                return null;
            }

                    }
                });
                CommonPoolUtil.execute(() -> {
                    try {
                        CloseableUtil.closeQuietly(p.getOutputStream());
                    } catch (final Exception e) {
                        logger.warn("Could not close a process output stream.", e);
                    }
                });

        public int exitValue() {
            return exitValue;
        }

        @Override
        public void destroy() {
        }

        @Override
        public java.io.OutputStream getOutputStream() {
            return null;
        }

        @Override
        public java.io.InputStream getInputStream() {
            return null;
        }

        @Override

        }

        @Override
        public String getContentType() {
            return headers.get("Content-Type");
        }

        @Override
        public jakarta.servlet.ServletOutputStream getOutputStream() {
            return null;
        }

        @Override
        public void setCharacterEncoding(String charset) {
        }

        @Override
        public void setContentLength(int len) {

        .throttleBody(3, 500, TimeUnit.MILLISECONDS),
    )
    val startNanos = System.nanoTime()
    val connection = server.url("/").toUrl().openConnection()
    connection.setDoOutput(true)
    connection.getOutputStream().write("ABCDEF".toByteArray(StandardCharsets.UTF_8))
    val inputStream = connection.getInputStream()
    assertThat(inputStream.read()).isEqualTo(-1)
    val elapsedNanos = System.nanoTime() - startNanos