}

    @Override
    public void completed(ProgressCompleteEvent event) {
        listener.onOutput(event);
    }

    @Override
    public void started(ProgressStartEvent event) {
        listener.onOutput(event);
    }

    @Override
    public void progress(ProgressEvent event) {
        listener.onOutput(event);
    }

    private final OutputEventListener broadcaster = new OutputEventListener() {
        @Override
        public void onOutput(OutputEvent event) {
            renderer.onOutput(event);

            OutputEventListener otherRef = other;
            if (otherRef != null) {
                otherRef.onOutput(event);
            }
        }
    };

    public OutputEventListenerManager(OutputEventListener renderer) {

    }

    @Override
    public void sendOutputEvent(LogEvent event) {
        outputEventListener.onOutput(event);
    }

    @Override
    public void sendOutputEvent(StyledTextOutputEvent event) {
        outputEventListener.onOutput(event);
    }

    }

    @Override
    public void onOutput(OutputEvent event) {
        if (event.getLogLevel() != null && event.getLogLevel().compareTo(logLevel) < 0) {
            return;
        }
        if (event instanceof LogLevelChangeEvent) {
            LogLevelChangeEvent changeEvent = (LogLevelChangeEvent) event;
            logLevel = changeEvent.getNewLogLevel();
        }
        listener.onOutput(event);
    }

 * limitations under the License.
 */

package org.gradle.internal.logging.events;

public interface OutputEventListener {
    void onOutput(OutputEvent event);

    OutputEventListener NO_OP = new OutputEventListener() {
        @Override
        public void onOutput(OutputEvent event) {
        }
    };

        } else if (!(event instanceof ProgressEvent)) {
            listener.onOutput(event);
        }
    }

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

    private void onComplete(ProgressCompleteEvent progressCompleteEvent) {

    public AbstractUserInputRenderer(OutputEventListener delegate, GlobalUserInputReceiver userInput) {
        this.delegate = delegate;
        this.userInput = userInput;
    }

    @Override
    public void onOutput(OutputEvent event) {
        if (event instanceof UserInputRequestEvent) {
            handleUserInputRequestEvent();
            return;
        } else if (event instanceof UserInputResumeEvent) {

    }

    private void onTextEvent(StyledTextOutputEvent textOutputEvent) {
        if (textOutputEvent.getLogLevel() != null) {
            listener.onOutput(textOutputEvent);
        } else {
            listener.onOutput(textOutputEvent.withLogLevel(logLevel.get()));
        }
    }

                    LOGGER.debug("Exception while displaying output", t);
                }
            }
        }, throttleMs, throttleMs, TimeUnit.MILLISECONDS);
    }

    @Override
    public void onOutput(OutputEvent newEvent) {
        synchronized (lock) {
            queue.add(newEvent);

            if (queue.size() == 10000) {

    }

    @Override
    void startInput() {
    }

    @Override
    void handlePrompt(RenderableOutputEvent event) {
        delegate.onOutput(event);
    }

    @Override
    void finishInput(RenderableOutputEvent event) {
        delegate.onOutput(event);
    }