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

public interface ResultHandlerVersion1<T> {
    void onComplete(T result);

    void onFailure(Throwable failure);

import org.gradle.tooling.internal.consumer.connection.ConsumerConnection
import org.gradle.tooling.internal.consumer.parameters.ConsumerOperationParameters
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1
import spock.lang.Specification

class DefaultTestLauncherTest extends Specification {
    def executor = Mock(AsyncConsumerActionExecutor)
    def connection = Mock(ConsumerConnection)

import org.gradle.tooling.ResultHandler;
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1;

/**
 * Adapts a {@link ResultHandler} to a {@link ResultHandlerVersion1}.
 *
 * @param <T> The result type.
 */
public class ResultHandlerAdapter<T> implements ResultHandlerVersion1<T> {
    private final ResultHandler<? super T> handler;

import org.gradle.tooling.internal.consumer.connection.ConsumerConnection
import org.gradle.tooling.internal.consumer.parameters.ConsumerOperationParameters
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1

class DefaultPhasedBuildActionExecuterTest extends ConcurrentSpec {
    // Tests based on DefaultBuildActionExecuterTest

    def asyncConnection = Mock(AsyncConsumerActionExecutor) {

import org.gradle.tooling.internal.protocol.ResultHandlerVersion1

class DefaultAsyncConsumerActionExecutorTest extends ConcurrentSpec {
    def actionExecuter = Mock(ConsumerActionExecutor) {
        getDisplayName() >> "[executer]"
    }
    def action = Mock(ConsumerAction)
    def handler = Mock(ResultHandlerVersion1)

import org.gradle.tooling.internal.consumer.connection.ConsumerConnection
import org.gradle.tooling.internal.consumer.parameters.ConsumerOperationParameters
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1
import org.gradle.tooling.model.GradleProject
import org.gradle.tooling.model.internal.Exceptions

class DefaultModelBuilderTest extends ConcurrentSpec {
    final AsyncConsumerActionExecutor asyncConnection = Mock()

import org.gradle.tooling.internal.gradle.TaskListingLaunchable
import org.gradle.tooling.internal.protocol.InternalLaunchable
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1
import org.gradle.tooling.model.GradleProject
import org.gradle.tooling.model.Launchable
import org.gradle.tooling.model.Task
import org.gradle.tooling.model.TaskSelector

import org.gradle.tooling.internal.consumer.connection.ConsumerConnection
import org.gradle.tooling.internal.consumer.parameters.ConsumerOperationParameters
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1
import org.gradle.tooling.model.GradleProject

class DefaultBuildActionExecuterTest extends ConcurrentSpec {
    def asyncConnection = Mock(AsyncConsumerActionExecutor)
    def connection = Mock(ConsumerConnection)

 * limitations under the License.
 */
package org.gradle.tooling.internal.consumer.async;

import org.gradle.tooling.internal.consumer.connection.ConsumerAction;
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1;

/**
 * Implementations must be thread-safe.
 */
public interface AsyncConsumerActionExecutor {
    /**

import org.gradle.tooling.internal.consumer.connection.ConsumerAction;
import org.gradle.tooling.internal.consumer.connection.ConsumerActionExecutor;
import org.gradle.tooling.internal.protocol.ResultHandlerVersion1;

/**
 * Adapts a {@link ConsumerActionExecutor} to an {@link AsyncConsumerActionExecutor}.
 */
public class DefaultAsyncConsumerActionExecutor implements AsyncConsumerActionExecutor {