dead - Code Search

android/guava/src/com/google/common/io/ByteSource.java

 *       block indefinitely or fail if the source creates an infinite stream.
 *   <li><b>Non-destructive:</b> A <i>destructive</i> stream will consume or otherwise alter the
 *       bytes of the source as they are read from it. A source that provides such streams will not
 *       be reusable, and operations that read from the stream (including {@link #size()}, in some

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Mon Sep 08 18:35:13 GMT 2025

- 25.7K bytes

- Click Count (0)

github.com/google/guava

android/guava-tests/benchmark/com/google/common/cache/ChainBenchmark.java

      if (i == 0) {
        head = chain;
      }
    }
  }

  @SuppressWarnings("GuardedBy")
  @Benchmark
  int time(int reps) {
    int dummy = 0;
    for (int i = 0; i < reps; i++) {
      // TODO(b/145386688): This access should be guarded by 'this.segment', which is not currently
      // held
      segment.removeEntryFromChain(chain, head);
      dummy += segment.count;
    }

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Sun Dec 22 03:38:46 GMT 2024

- 2.1K bytes

- Click Count (0)

github.com/square/okhttp

okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerAdapter.kt

   * a default value.
   *
   * If this does read a value, it starts with the tag and length, and reads an entire value,
   * including any potential composed values.
   *
   * If there's nothing to read and no default value, this will throw an exception.
   */
  fun fromDer(reader: DerReader): T

  fun fromDer(byteString: ByteString): T {

Created: Fri Dec 26 11:42:13 GMT 2025

- Last Modified: Wed Mar 19 19:25:20 GMT 2025

- 4.2K bytes

- Click Count (0)

github.com/golang/go

src/archive/zip/register.go

	return &pooledFlateReader{fr: fr}
}

type pooledFlateReader struct {
	mu sync.Mutex // guards Close and Read
	fr io.ReadCloser
}

func (r *pooledFlateReader) Read(p []byte) (n int, err error) {
	r.mu.Lock()
	defer r.mu.Unlock()
	if r.fr == nil {
		return 0, errors.New("Read after Close")
	}
	return r.fr.Read(p)
}

func (r *pooledFlateReader) Close() error {
	r.mu.Lock()
	defer r.mu.Unlock()
	var err error

Created: Tue Dec 30 11:13:12 GMT 2025

- Last Modified: Fri Oct 13 18:36:46 GMT 2023

- 3.7K bytes

- Click Count (0)

github.com/minio/minio

docs/site-replication/run-replication-with-checksum-header.sh

fi

# Stat the objects from source site
echo "Stat minio1/test-bucket/obj"
SRC_OUT_1=$(aws s3api --endpoint-url https://localhost:9001 head-object --bucket test-bucket --key obj --checksum-mode ENABLED --no-verify-ssl --profile enterprise)
SRC_OUT_2=$(aws s3api --endpoint-url https://localhost:9001 head-object --bucket test-bucket --key mpartobj --checksum-mode ENABLED --no-verify-ssl --profile enterprise)

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Mon Jan 20 14:49:07 GMT 2025

- 11.5K bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/custom_response/tutorial004_py39.py

from fastapi import FastAPI
from fastapi.responses import HTMLResponse

app = FastAPI()


def generate_html_response():
    html_content = """
    <html>
        <head>
            <title>Some HTML in here</title>
        </head>
        <body>
            <h1>Look ma! HTML!</h1>
        </body>
    </html>
    """
    return HTMLResponse(content=html_content, status_code=200)

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Wed Dec 17 20:41:43 GMT 2025

- 491 bytes

- Click Count (0)

github.com/tiangolo/fastapi

docs_src/request_files/tutorial001_03_py39.py

app = FastAPI()


@app.post("/files/")
async def create_file(file: bytes = File(description="A file read as bytes")):
    return {"file_size": len(file)}


@app.post("/uploadfile/")
async def create_upload_file(
    file: UploadFile = File(description="A file read as UploadFile"),
):

Created: Sun Dec 28 07:19:09 GMT 2025

- Last Modified: Wed Dec 17 20:41:43 GMT 2025

- 371 bytes

- Click Count (0)

github.com/minio/minio

internal/dsync/dsync-server_test.go

		return false, fmt.Errorf("RUnlock attempted on a write locked entity: %s", args.Resources[0])
	}
	if locksHeld > ReadLock {
		l.lockMap[args.Resources[0]] = locksHeld - ReadLock // Remove one of the read locks held
	} else {
		delete(l.lockMap, args.Resources[0]) // Remove the (last) read lock
	}
	return reply, nil
}

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Fri Aug 29 02:39:48 GMT 2025

- 8.3K bytes

- Click Count (0)

github.com/minio/minio

internal/s3select/json/preader.go

	dst   chan []jstream.KVS // result of block decode
	err   error              // any error encountered will be set here
}

// Read - reads single record.
// Once Read is called the previous record should no longer be referenced.
func (r *PReader) Read(dst sql.Record) (sql.Record, error) {
	// If we have have any records left, return these before any error.
	for len(r.current) <= r.recordsRead {
		if r.err != nil {

Created: Sun Dec 28 19:28:13 GMT 2025

- Last Modified: Tue May 27 15:19:03 GMT 2025

- 6.5K bytes

- Click Count (0)

github.com/google/guava

guava-tests/test/com/google/common/io/MultiInputStreamTest.java

    ByteStreams.skipFully(multi, 20);
    assertEquals(20, multi.read());
  }

  public void testReadSingle_noStackOverflow() throws IOException {
    // https://github.com/google/guava/issues/2996
    // no data, just testing that there's no StackOverflowException
    assertEquals(-1, tenMillionEmptySources().read());
  }

  public void testReadArray_noStackOverflow() throws IOException {

Created: Fri Dec 26 12:43:10 GMT 2025

- Last Modified: Tue Oct 28 18:44:53 GMT 2025

- 4.7K bytes

- Click Count (0)

Search Options