- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 100 for Biscardi (0.2 sec)
-
src/archive/zip/writer_test.go
Name: "foo", Method: Deflate, }) w.Write(bigBuf) } zw.Close() } b.ReportAllocs() // Run once and then reset the timer. // This effectively discards the very large initial flate setup cost, // as well as the initialization of bigBuf. runOnce(&bytes.Buffer{}) b.ResetTimer() b.RunParallel(func(pb *testing.PB) { var buf bytes.Buffer for pb.Next() {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Sep 15 19:04:06 GMT 2023 - 14.1K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEvents.java
} @Override public void onResponse(Call call, Response response) throws IOException { try (ResponseBody body = response.body()) { // Consume and discard the response body. body.source().readByteString(); } } }); Request newYorkTimesRequest = new Request.Builder() .url("https://www.nytimes.com/") .build();
Java - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 16 23:20:49 GMT 2020 - 6.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Stream.kt
} // If the peer sends more data than we can handle, discard it and close the connection. if (flowControlError) { source.skip(remainingByteCount) closeLater(ErrorCode.FLOW_CONTROL_ERROR) return } // Discard data received after the stream is finished. It's probably a benign race. if (finished) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 23.2K bytes - Viewed (1) -
src/archive/tar/reader.go
// one or more "header files" until it finds a "normal file". format := FormatUSTAR | FormatPAX | FormatGNU for { // Discard the remainder of the file and any padding. if err := discard(tr.r, tr.curr.physicalRemaining()); err != nil { return nil, err } if _, err := tryReadFull(tr.r, tr.blk[:tr.pad]); err != nil { return nil, err } tr.pad = 0
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Fri Mar 08 01:59:14 GMT 2024 - 26.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
* reuse, this timeout should be significantly less than the time it takes to establish a new * connection. */ const val DISCARD_STREAM_TIMEOUT_MILLIS = 100 }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3K bytes - Viewed (0) -
src/archive/zip/fuzz_test.go
continue } } // If we were unable to read anything out of the archive don't // bother trying to roundtrip it. if len(files) == 0 { return } w := NewWriter(io.Discard) for _, f := range files { ww, err := w.CreateHeader(f.header) if err != nil { t.Fatalf("unable to write previously parsed header: %s", err) } if _, err := ww.Write(f.content); err != nil {
Go - Registered: Tue Apr 30 11:13:12 GMT 2024 - Last Modified: Thu Jan 13 18:06:33 GMT 2022 - 1.7K bytes - Viewed (0) -
internal/bpool/bpool.go
func (bp *BytePoolCap) Put(b []byte) { if bp == nil { return } select { case bp.c <- b: // buffer went back into pool default: // buffer didn't go back into pool, just discard } } // Width returns the width of the byte arrays in this pool. func (bp *BytePoolCap) Width() (n int) { if bp == nil { return 0 } return bp.w }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 19 16:44:59 GMT 2024 - 2.6K bytes - Viewed (0) -
internal/s3select/select.go
return bytes.NewBuffer(make([]byte, 0, maxRecordSize)) }, } var bufioWriterPool = sync.Pool{ New: func() interface{} { // io.Discard is just used to create the writer. Actual destination // writer is set later by Reset() before using it. return bufio.NewWriter(xioutil.Discard) }, } // UnmarshalXML - decodes XML data. func (c *CompressionType) UnmarshalXML(d *xml.Decoder, start xml.StartElement) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/MockResponseSniTest.kt
.host(hostnameOrIpAddress) .build(), ), ) val response = call.execute() assertThat(response.isSuccessful).isTrue() server.takeRequest() // Discard the CONNECT tunnel. return server.takeRequest() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (1) -
build-logic/integration-testing/src/main/kotlin/gradlebuild.cross-version-tests.gradle.kts
this.systemProperties["org.gradle.integtest.crossVersion"] = "true" // We should always be using JUnitPlatform at this point, so don't call useJUnitPlatform(), else this will // discard existing options configuration and add a deprecation warning. Just set the existing options. (this.testFramework.options as JUnitPlatformOptions).includeEngines("cross-version-test-engine") }
Plain Text - Registered: Wed Mar 27 11:36:08 GMT 2024 - Last Modified: Sat Sep 30 16:17:28 GMT 2023 - 4.1K bytes - Viewed (0)