then:
        ConcurrentTestUtil.poll(buildTimeout, 0.5) {
            assert !gradle.isRunning()
        }

        where:
        [inputBefore, flushBefore] << [['', ' ', 'a', 'some input', 'a' * 8192], [true, false]].combinations()
    }

    def "does not cancel continuous build when other than ctrl+d is entered"() {
        given:
        setupJavaProject()

        when:
        succeeds("build")

    public ExecOutputHandleRunner(String displayName, InputStream inputStream, OutputStream outputStream, CountDownLatch completed) {
        this(displayName, inputStream, outputStream, 8192, completed);
    }

    ExecOutputHandleRunner(String displayName, InputStream inputStream, OutputStream outputStream, int bufferSize, CountDownLatch completed) {
        this.displayName = displayName;

/**
 * Transformed artifact is derived with some transformation from source artifact.
 *
 * @since TBD
 */
class TransformedArtifact extends DefaultArtifact {

    private static final int SHA1_BUFFER_SIZE = 8192;
    private final DefaultConsumerPomArtifactTransformer defaultConsumerPomArtifactTransformer;
    private final MavenProject project;
    private final Supplier<Path> sourcePathProvider;
    private final Path target;

 */
public class LineEndingNormalizingInputStreamHasher {
    private static final HashCode SIGNATURE = Hashing.signature(LineEndingNormalizingInputStreamHasher.class);
    private static final int BUFFER_SIZE = 8192;

    /**
     * Hash the contents of the provided input stream, normalizing line endings.
     *
     * @param inputStream The input stream to hash

    private final byte lastLineSeparatorByte;
    private final int lineMaxLength;
    private int counter;

    public LineBufferingOutputStream(TextStream handler, String lineSeparator) {
        this(handler, lineSeparator, 8192);
    }

    public LineBufferingOutputStream(TextStream handler, String lineSeparator, int bufferLength) {
        this(handler, lineSeparator, bufferLength, LINE_MAX_LENGTH);
    }

         26:b5:cd:64:f0:94:fa:9e:7f:86:6e:9c:64:ed:e2:dc:7b:97:
         8d:14:95:33:1d:8e:08:20:ca:4d:3b:25:53:6a:5f:5f:9c:fc:
         d7:cb:3f:c8:7d:1e:ee:17:ea:a0:ec:4f:ef:f8:a0:47:8c:35:
         99:44:bd:60:c8:34:ee:55:53:9f:81:92:a7:2c:2d:7b:a3:50:
         f0:02:b9:fb:fa:98:f4:d6:6d:ba:da:bd:fe:88:a7:db:a3:78:
         0a:af:2e:fc:25:f2:e1:96:a8:de:15:14:f4:ef:0c:af:a0:2c:
         7c:3a:91:aa:fa:d9:cd:80:53:77:0b:7b:5b:e0:d6:87:47:38:

	srcBuf := bytes.NewBuffer(make([]byte, 8192))
	src := NewReader(onlyReader{srcBuf})
	dstBuf := new(bytes.Buffer)
	dst := onlyWriter{dstBuf}
	for i := 0; i < b.N; i++ {
		srcBuf.Reset()
		src.Reset(onlyReader{srcBuf})
		dstBuf.Reset()
		io.Copy(dst, src)
	}
}

func BenchmarkReaderCopyNoWriteTo(b *testing.B) {
	srcBuf := bytes.NewBuffer(make([]byte, 8192))
	srcReader := NewReader(srcBuf)

	nbuf int     // length of buf; return value from Getdirentries
	bufp int     // location of next record in buf.
}

const (
	// More than 5760 to work around https://golang.org/issue/24015.
	blockSize = 8192
)

var dirBufPool = sync.Pool{
	New: func() any {
		// The buffer must be at least a block long.
		buf := make([]byte, blockSize)
		return &buf
	},
}

func (d *dirInfo) close() {
	if d.buf != nil {

import java.util.HashSet;
import java.util.Objects;
import java.util.Set;

@NonNullApi
public class InPlaceClasspathBuilder implements ClasspathBuilder {
    private static final int BUFFER_SIZE = 8192;

    @Override
    public void jar(File jarFile, Action action) {
        try {
            buildJar(jarFile, action);
        } catch (Exception e) {

	DISPATCH(runtime·call256, 256)
	DISPATCH(runtime·call512, 512)
	DISPATCH(runtime·call1024, 1024)
	DISPATCH(runtime·call2048, 2048)
	DISPATCH(runtime·call4096, 4096)
	DISPATCH(runtime·call8192, 8192)
	DISPATCH(runtime·call16384, 16384)
	DISPATCH(runtime·call32768, 32768)
	DISPATCH(runtime·call65536, 65536)
	DISPATCH(runtime·call131072, 131072)
	DISPATCH(runtime·call262144, 262144)