textOut.text("styled text message from thread ")
                    textOut.style(UserInput).text(thread).style(Normal)
                    textOut.text(' iteration ')
                    textOut.style(UserInput).text(iteration).style(Normal)
                    textOut.println()
                }
            }
        }

        executor.shutdown()

    private final ForwardingUserInput forwarder;
    private final GlobalUserInputReceiver userInput;
    private final ExecutorService executor;

    public DaemonClientInputForwarder(
        InputStream inputStream,
        Dispatch<? super InputMessage> dispatch,
        GlobalUserInputReceiver userInput
    ) {
        this.userInput = userInput;

public class UserInputConsoleRenderer extends AbstractUserInputRenderer {
    private final Console console;

    public UserInputConsoleRenderer(OutputEventListener delegate, Console console, GlobalUserInputReceiver userInput) {
        super(delegate, userInput);
        this.console = console;
    }

    @Override
    void startInput() {
        toggleBuildProgressAreaVisibility(false);
        flushConsole();
    }

    @Override

 */

package org.gradle.execution;

import org.gradle.api.InvalidUserDataException;
import org.gradle.internal.exceptions.FailureResolutionAware;

import static org.gradle.internal.logging.text.StyledTextOutput.Style.UserInput;

abstract class BaseSelectionException extends InvalidUserDataException implements FailureResolutionAware {
    private final String taskName;
    private final String targetName;

 * limitations under the License.
 */

package org.gradle.tooling.internal.provider;

import org.gradle.api.internal.file.FileCollectionFactory;
import org.gradle.api.internal.tasks.userinput.UserInputReader;
import org.gradle.initialization.layout.BuildLayoutFactory;
import org.gradle.internal.daemon.client.serialization.ClasspathInferer;

    def console = Mock(Console)
    def buildProgressArea = Mock(BuildProgressArea)
    def textArea = Mock(TextArea)
    def userInput = Mock(GlobalUserInputReceiver)
    @Subject def renderer = new UserInputConsoleRenderer(listener, console, userInput)

    def "can handle user input request and resume events"() {
        given:
        def prompt = Mock(PromptOutputEvent)

        context.appendResolution(output -> {
            output.text("Run ");
            context.getClientMetaData().describeCommand(output.withStyle(UserInput), ProjectInternal.HELP_TASK);
            output.withStyle(UserInput).format(" --task %s", taskPath);
            output.text(" to get task usage details.");
        });
    }

 * limitations under the License.
 */

package org.gradle.internal.daemon.services;

import org.gradle.api.internal.tasks.userinput.DefaultUserInputReader;
import org.gradle.api.internal.tasks.userinput.UserInputReader;
import org.gradle.internal.classpath.CachedClasspathTransformer;
import org.gradle.internal.daemon.serialization.DaemonSidePayloadClassLoaderFactory;

        InputStream buildStandardInput,
        GlobalUserInputReceiver userInput,
        IdGenerator<UUID> idGenerator,
        DocumentationRegistry documentationRegistry,
        ProcessEnvironment processEnvironment
    ) {
        super(connector, outputEventListener, compatibilitySpec, buildStandardInput, userInput, idGenerator, processEnvironment);
        this.documentationRegistry = documentationRegistry;
    }

    protected DefaultUserInputReceiver createUserInput() {
        return userInput;
    }

    // Intentionally not a “create” method as this should not be exposed as a service
    protected OutputEventRenderer makeOutputEventRenderer() {
        OutputEventRenderer eventRenderer = new OutputEventRenderer(Time.clock(), userInput);
        userInput.attachConsole(eventRenderer);
        return eventRenderer;
    }