* See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.gradle.launcher.daemon.protocol;

public abstract class InputMessage extends Message {

        private final Dispatch<? super InputMessage> dispatch;
        private final BufferedReader reader;
        private final Executor executor;
        private char[] buffer;

        // Protects the following state
        private final Object lock = new Object();
        private boolean closed;

        public ForwardingUserInput(InputStream inputStream, Dispatch<? super InputMessage> dispatch, Executor executor) {

 */

package org.gradle.launcher.daemon.protocol;

/**
 * Carries the user's response to a {@link org.gradle.internal.logging.events.PromptOutputEvent}.
 */
public class UserResponse extends InputMessage {
    private final String response;

    public UserResponse(String response) {
        this.response = response;
    }

    public String getResponse() {
        return response;
    }

 * limitations under the License.
 */
package org.gradle.launcher.daemon.protocol;

/**
 * Carries some text that should be made available via the daemon's System.in
 */
public class ForwardInput extends InputMessage {
    private final byte[] bytes;

    public ForwardInput(byte[] bytes) {
        this.bytes = bytes;
    }

    public byte[] getBytes() {
        return bytes;
    }

                            return;
                        }

                        if (message instanceof InputMessage) {
                            LOGGER.debug("thread {}: Received IO message from client: {}", Thread.currentThread().getId(), message);
                            stdinQueue.add((InputMessage) message);
                        } else if (message instanceof Cancel) {

 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.gradle.launcher.daemon.protocol;

public class CloseInput extends InputMessage {

import org.gradle.launcher.daemon.server.api.DaemonCommandExecution;
import org.gradle.internal.daemon.clientinput.ClientInputForwarder;

/**
 * Listens for {@link org.gradle.launcher.daemon.protocol.InputMessage} commands during execution and forwards them to this process' System.in and services such
 * as {@link UserInputReader}.
 */
public class ForwardClientInput implements DaemonCommandAction {

Class <org.gradle.launcher.daemon.protocol.InputMessage> is not annotated (directly or via its package) with @org.gradle.api.NonNullApi in (InputMessage.java:0)