this(new OutputStreamWriter(outputStream, Charset.defaultCharset()));
    }

    @Override
    public void onOutput(CharSequence output) {
        try {
            appendable.append(output);
            flushable.flush();
        } catch (IOException e) {
            throw new UncheckedIOException(e);
        }
    }

     */
    void onOutput(TestDescriptor testDescriptor, TestOutputEvent outputEvent);

            </tr>
            <tr>
                <td>beforeTest</td>
            </tr>
            <tr>
                <td>afterTest</td>
            </tr>
            <tr>
                <td>onOutput</td>
            </tr>
            <tr>
                <td>reports</td>
            </tr>
            <tr>
                <td>setTestNameIncludePatterns</td>
            </tr>
        </table>

    private final Object lock;

    public OutputEventTransformer(OutputEventListener listener, Object lock) {
        this.listener = listener;
        this.lock = lock;
    }

    @Override
    public void onOutput(OutputEvent event) {
        if (event instanceof ProgressStartEvent) {
            ProgressStartEvent startEvent = (ProgressStartEvent) event;
            if (!startEvent.isBuildOperationStart()) {

    @Override
    String toString() {
        return writer.toString()
    }

    void reset() {
        writer
    }

    @Override
    synchronized void onOutput(OutputEvent event) {
        if(event instanceof LogEvent){
            LogEvent logEvent = event as LogEvent
            writer.append("[")
            writer.append(logEvent.toString())
            writer.append("]")

                void afterTest(TestDescriptor testDescriptor, TestResult result) {}
            }
            def testOutputListener = new TestOutputListener() {
                void onOutput(TestDescriptor testDescriptor, TestOutputEvent outputEvent) {}
            }
            gradle.addListener($listener)
            task broken
        """

        when:

class CollectingTestOutputEventListener implements OutputEventListener {
    final List<LogEvent> events = new ArrayList<>()

    void reset() {
        events.clear()
    }

    @Override
    synchronized void onOutput(OutputEvent event) {
        LogEvent logEvent = event as LogEvent
        events.add(logEvent)
    }

    void stop();

    void redirectStandardOutputTo(OutputListener stdOutDestination);

    void redirectStandardErrorTo(OutputListener stdErrDestination);

    interface OutputListener {
        void onOutput(CharSequence output);
    }

        }
    }

    @Override
    public void onOutput(OutputEvent event) {
        WorkerLoggingProtocol loggingProtocol = workerLoggingProtocol.get();

        if (loggingProtocol == null) {
            throw new IllegalStateException(getClass().getSimpleName() + " received an output event before the worker logging protocol object was set.");
        }

        this.listener = listener;
        this.buildStatusLabel = buildStatusLabel;
        this.console = console;
        this.consoleMetaData = consoleMetaData;
    }

    @Override
    public void onOutput(OutputEvent event) {
        if (event instanceof ProgressStartEvent) {
            ProgressStartEvent startEvent = (ProgressStartEvent) event;
            if (startEvent.isBuildOperationStart()) {