onComplete((ProgressCompleteEvent) event);
        } else if (event instanceof RenderableOutputEvent) {
            doOutput((RenderableOutputEvent) event);
        } else if (!(event instanceof ProgressEvent)) {
            listener.onOutput(event);
        }
    }

    private void doOutput(RenderableOutputEvent event) {
        for (Operation operation : operations.values()) {
            operation.completeHeader();

        this.doInput = doInput;
    }

    public boolean getDoInput() {
        return connection.getDoInput();
    }

    public void setDoOutput(boolean doOutput) {
        connection.setDoOutput(doOutput);
        this.doOutput = doOutput;
    }

    public boolean getDoOutput() {
        return connection.getDoOutput();
    }

    public void setAllowUserInteraction(boolean allowUserInteraction) {

    @Override
    public boolean getDoInput () {
        return this.connection.getDoInput();
    }


    @Override
    public void setDoOutput ( boolean doOutput ) {
        this.connection.setDoOutput(doOutput);
        this.doOutput = doOutput;
    }


    @Override
    public boolean getDoOutput () {
        return this.connection.getDoOutput();
    }


    @Override

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

        server.expect(server.put("a"))
        server.start()

        when:
        def connection = server.uri("a").toURL().openConnection()
        connection.requestMethod = 'PUT'
        connection.doOutput = true
        connection.outputStream << "123".bytes
        connection.inputStream.text

        server.stop()

        then:
        noExceptionThrown()
    }

     * <code>URL</code> may be used as any other <code>URL</code> might to
     * access an SMB resource. Currently only retrieving data and information
     * is supported (i.e. no <tt>doOutput</tt>).
     *
     * @deprecated Use getURL() instead
     * @return A new <code>{@link java.net.URL}</code> for this <code>SmbFile</code>
     */
    @Deprecated
    public URL toURL () {

 * <code>URL</code> may be used as any other <code>URL</code> might to
 * access an SMB resource. Currently only retrieving data and information
 * is supported (i.e. no <tt>doOutput</tt>).
 *
 * @deprecated Use getURL() instead
 * @return A new <code>{@link java.net.URL}</code> for this <code>SmbFile</code>
 * @throws MalformedURLException
 */

            return false;
        }
        Output output = (Output) o;
        return Objects.equal(path, output.path);
    }

    @Override
    public int hashCode() {
        return Objects.hashCode(path);
    }

    @Override
    public String toString() {
        return "Output{path='" + path + "'}";
    }

	cmd.Flags().StringVarP(pf.OutputFormat, "output", "o", *pf.OutputFormat, fmt.Sprintf("Output format. One of: %s.", strings.Join(pf.AllowedFormats(), "|")))
	cmd.Flags().StringVarP(pf.OutputFormat, "experimental-output", "", *pf.OutputFormat, fmt.Sprintf("Output format. One of: %s.", strings.Join(pf.AllowedFormats(), "|")))
	_ = cmd.Flags().MarkDeprecated("experimental-output", "please use --output instead.")
}

Xiaopeng Han <******@****.***> 1686064488 +0800