go func() {
		// In order to generate the nth prime we only need multiples of
		// primes ≤ sqrt(nth prime).  Thus, the merging goroutine will
		// receive from 'primes' much slower than this goroutine
		// will send to it, making the buffer accumulate and block this
		// goroutine from sending, causing a deadlock.  The solution is to
		// use a proxy goroutine to do automatic buffering.
		primes := sendproxy(primes)

		candidates := odds()

                classpath = project.layout.files(compileJava)
                mainClass = "driver.Driver"
                args "1"
            }
        """
    }

    @Override
    protected void writeSucceedingExec() {
        mainJavaFile = file('src/main/java/Driver.java')
        file("src/main/java/Driver.java").text = mainClass("""
            try {
                FileWriter out = new FileWriter("out.txt");

        final int result = copy(url, "UTF-8", writer);
        assertThat(result, is(urlString.length()));
        assertThat(writer.toString(), is(urlString));
    }

    /**
     * @throws Exception
     */
    @Test
    public void testFileToWriter() throws Exception {
        final int result = copy(inputFile, "UTF-8", writer);
        assertThat(result, is(urlString.length()));

import java.io.IOException;
import java.io.UncheckedIOException;
import java.io.Writer;

public class ProjectAccessorsSourceGenerator extends AbstractProjectAccessorsSourceGenerator {

    public ProjectAccessorsSourceGenerator(Writer writer) {
        super(writer);
    }

    public static String generateSource(Writer writer,
                                        ProjectDescriptor current,

import java.io.UncheckedIOException;
import java.io.Writer;

public class RootProjectAccessorSourceGenerator extends AbstractProjectAccessorsSourceGenerator {

    public static final String ROOT_PROJECT_ACCESSOR_CLASSNAME = "RootProjectAccessor";

    public RootProjectAccessorSourceGenerator(Writer writer) {
        super(writer);
    }

    public static void generateSource(Writer writer,

    @Override
    public void writeAllOutput(final long classId, final TestOutputEvent.Destination destination, final Writer writer) {
        withReader(new Action<TestOutputStore.Reader>() {
            @Override
            public void execute(TestOutputStore.Reader reader) {
                reader.writeAllOutput(classId, destination, writer);
            }
        });
    }

    @Override

                args '-cp', project.layout.files(compileJava).asPath, 'driver.Driver', "1"
            }
        """
    }

    @Override
    protected void writeSucceedingExec() {
        mainJavaFile = file('src/main/java/Driver.java')
        file("src/main/java/Driver.java").text = mainClass("""
            try {
                FileWriter out = new FileWriter("out.txt");

    public AbstractSourceGenerator(Writer writer) {
        this.writer = writer;
    }

    static String toJavaName(String alias) {
        return nameSplitter()
            .splitToList(alias)
            .stream()
            .map(StringUtils::capitalize)
            .collect(Collectors.joining());
    }

    protected static Splitter nameSplitter() {
        return Splitter.on(SEPARATOR_PATTERN);
    }

                                writer.write(hit.getSourceAsString());
                                writer.write("\n");
                            } catch (final IOException e) {
                                throw new IORuntimeException(e);
                            }
                            return true;
                        });
                        writer.flush();
                    }
                });

                    JavaFileObject javaFile = filer.createSourceFile("ServiceRegistry", new Element[0]);
                    Writer writer = javaFile.openWriter();
                    try {
                        writer.write("class ServiceRegistry {}");
                    } finally {
                        writer.close();
                    }
                }
                if (roundEnv.processingOver()) {