- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 90 for Rischard (0.21 sec)
-
internal/ioutil/discard.go
import ( "io" ) // Discard is just like io.Discard without the io.ReaderFrom compatible // implementation which is buggy on NUMA systems, we have to use a simpler // io.Writer implementation alone avoids also unnecessary buffer copies, // and as such incurred latencies. var Discard io.Writer = discard{} // discard is /dev/null for Golang. type discard struct{} func (discard) Write(p []byte) (int, error) {
Go - Registered: Sun Apr 07 19:28:10 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 1.3K bytes - Viewed (0) -
src/bytes/reader_test.go
n int64 err error } type justReader struct { io.Reader } type justWriter struct { io.Writer } discard := justWriter{io.Discard} // hide ReadFrom var with, withOut nErr with.n, with.err = io.Copy(discard, NewReader(nil)) withOut.n, withOut.err = io.Copy(discard, justReader{NewReader(nil)}) if with != withOut { t.Errorf("behavior differs: with = %#v; without: %#v", with, withOut) } }
Go - Registered: Tue Apr 16 11:13:10 GMT 2024 - Last Modified: Mon Dec 13 18:45:54 GMT 2021 - 8K bytes - Viewed (0) -
logger/logger.go
Error(context.Context, string, ...interface{}) Trace(ctx context.Context, begin time.Time, fc func() (sql string, rowsAffected int64), err error) } var ( // Discard logger will print any log to io.Discard Discard = New(log.New(io.Discard, "", log.LstdFlags), Config{}) // Default Default logger Default = New(log.New(os.Stdout, "\r\n", log.LstdFlags), Config{ SlowThreshold: 200 * time.Millisecond,
Go - Registered: Sun Apr 14 09:35:11 GMT 2024 - Last Modified: Tue Nov 07 02:19:41 GMT 2023 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt
val request = Request(server.url("/")) val response1 = client.newCall(request).execute() val response2 = client.newCall(request).execute() response1.body.string() // Discard the response body. response2.body.string() // Discard the response body. assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) assertThat(server.takeRequest().sequenceNumber).isEqualTo(1) } @Test
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 12.3K bytes - Viewed (0) -
src/bufio/bufio_test.go
br.ReadRune() br.Discard(1) if err := br.UnreadRune(); err == nil { t.Error("UnreadRune didn't fail after Discard") } } func TestNoUnreadByteAfterDiscard(t *testing.T) { br := NewReader(strings.NewReader("example")) br.ReadByte() br.Discard(1) if err := br.UnreadByte(); err == nil { t.Error("UnreadByte didn't fail after Discard") } }
Go - Registered: Tue Apr 16 11:13:10 GMT 2024 - Last Modified: Fri Feb 10 18:56:01 GMT 2023 - 51.5K bytes - Viewed (0) -
cmd/storage-datatypes_test.go
MountPath: "/tmp/drive1", ID: "uuid", Error: "", } b.SetBytes(1) b.ReportAllocs() b.ResetTimer() for i := 0; i < b.N; i++ { err := msgp.Encode(io.Discard, &v) if err != nil { b.Fatal(err) } } } func BenchmarkEncodeDiskInfoGOB(b *testing.B) { v := DiskInfo{ Total: 1000, Free: 1000, Used: 1000,
Go - Registered: Sun Apr 14 19:28:10 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 9.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt
responseBodyComplete() } return read } override fun close() { if (closed) return if (bytesRemaining != 0L && !discard(ExchangeCodec.DISCARD_STREAM_TIMEOUT_MILLIS, MILLISECONDS) ) { carrier.noNewExchanges() // Unread bytes remain on the stream. responseBodyComplete() } closed = true } }
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 16.2K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PrintEventsNonConcurrent.java
try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } System.out.println("REQUEST 2 (pooled connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } }
Java - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Feb 16 23:20:49 GMT 2020 - 5.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 10.2K bytes - Viewed (0) -
docs/features/events.md
System.out.println("REQUEST 1 (new connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } System.out.println("REQUEST 2 (pooled connection)"); try (Response response = client.newCall(request).execute()) { // Consume and discard the response body. response.body().source().readByteString(); } ```
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0)