import spock.lang.Subject

class UserInputStandardOutputRendererTest  extends Specification {
    def listener = Mock(OutputEventListener)
    def userInput = Mock(GlobalUserInputReceiver)
    @Subject def renderer = new UserInputStandardOutputRenderer(listener, userInput)

    def "can handle user input request and resume events"() {
        given:
        def userInputRequestEvent = new UserInputRequestEvent()

    private final GlobalUserInputReceiver userInput;
    private final List<OutputEvent> eventQueue = new ArrayList<OutputEvent>();
    private boolean paused;

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

    @Override
    public void onOutput(OutputEvent event) {

            for (TaskDetails task : tasksByType) {
                pathOutput.withStyle(UserInput).println(task.getPath());
            }

            output.println();
            final LinePrefixingStyledTextOutput typeOutput = createIndentedOutput(output, INDENT);
            typeOutput.println("Type");
            typeOutput.withStyle(UserInput).text(shortTypeName);
            typeOutput.println(" (" + taskType + ")");

     */
    void startInput();

    void putInput(UserInput input);

    /**
     * Returns a {@link TextResponse} containing text supplied by the user, or {@link #END_OF_INPUT} if interrupted.
     */
    UserInput readInput();

    abstract class UserInput {
        abstract String getText();
    }

    UserInput END_OF_INPUT = new UserInput() {
        @Override
        String getText() {

import org.gradle.api.internal.tasks.userinput.BuildScanUserInputHandler;
import org.gradle.api.internal.tasks.userinput.DefaultBuildScanUserInputHandler;
import org.gradle.api.internal.tasks.userinput.DefaultUserInputHandler;
import org.gradle.api.internal.tasks.userinput.NonInteractiveUserInputHandler;
import org.gradle.api.internal.tasks.userinput.UserInputHandler;
import org.gradle.api.internal.tasks.userinput.UserInputReader;

        UserInputReceiver userInput = getDelegate();
        userInput.readAndForwardStdin();
    }

    private UserInputReceiver getDelegate() {
        UserInputReceiver userInput = delegate.get();
        if (userInput == null) {
            throw new IllegalStateException("User input has not been initialized.");
        }
        return userInput;
    }

    @Override

        def handle = withWatchFs().executer.withTasks(task).start()
        def userInput = server.expectAndBlock(expectedCall)
        userInput.waitForAllPendingCalls()
        action()
        userInput.releaseAll()
        result = handle.waitForFinish()
    }

    int getProjectFilesInVfs() {

        List spans = [new StyledTextOutputEvent.Span(StyledTextOutput.Style.UserInput, 'message')]
        def event = new StyledTextOutputEvent(100, 'category', LogLevel.LIFECYCLE, null, spans)

        when:
        event.render(output)

        then:
        1 * output.style(StyledTextOutput.Style.UserInput)
        1 * output.text('message')
        0 * output._
    }

            output.text("To create a new build in this directory, run ");
            metaData.describeCommand(output.withStyle(UserInput), "init");
            output.println();
            output.println();
            output.append("For more detail on the 'init' task, see ");
            output.withStyle(UserInput).append(getDocumentationRegistry().getDocumentationFor("build_init_plugin"));
            output.println();

 * limitations under the License.
 */

package org.gradle.api.internal.tasks.userinput;

import org.gradle.internal.UncheckedException;

public class DefaultUserInputReader implements UserInputReader {
    private final Object lock = new Object();
    private UserInput pending;
    private boolean finished;

    @Override
    public void startInput() {
        synchronized (lock) {