import org.gradle.tooling.model.eclipse.EclipseProject;

import java.io.IOException;
import java.net.URI;

class BlockingModelSendingBuildAction implements BuildAction<CustomModel> {
    private final URI uri;

    public BlockingModelSendingBuildAction(URI uri) {
        this.uri = uri;
    }

    @Override
    public CustomModel execute(BuildController controller) {

        def handler = { model ->
            models.add(model)
            finished.countDown()
        } as ResultHandler

        withConnection {
            def builder = it.action(new BlockingModelSendingBuildAction(server.uri("action")))
            collectOutputs(builder)
            builder.setStreamedValueListener(listener)
            builder.run(handler)

            modelReceived.await()