Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 121 for discard (0.05 sec)

  1. 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) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Nov 06 22:26:08 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  2. src/bufio/bufio_test.go

    				continue
    			}
    		}
    		discarded, err := br.Discard(tt.n)
    		if ge, we := fmt.Sprint(err), fmt.Sprint(tt.wantErr); discarded != tt.want || ge != we {
    			t.Errorf("%s: Discard(%d) = (%v, %v); want (%v, %v)", tt.name, tt.n, discarded, ge, tt.want, we)
    			continue
    		}
    		if bn := br.Buffered(); bn != tt.wantBuffered {
    			t.Errorf("%s: after Discard, Buffered = %d; want %d", tt.name, bn, tt.wantBuffered)
    		}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Fri Nov 01 21:52:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/cache/CacheInterceptor.kt

    import okhttp3.Interceptor
    import okhttp3.Protocol
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.internal.closeQuietly
    import okhttp3.internal.connection.RealCall
    import okhttp3.internal.discard
    import okhttp3.internal.http.ExchangeCodec
    import okhttp3.internal.http.HttpMethod
    import okhttp3.internal.http.RealResponseBody
    import okhttp3.internal.http.promisesBody
    import okhttp3.internal.stripBody
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Fri Mar 22 07:09:21 UTC 2024
    - 10.2K bytes
    - Viewed (0)
  4. 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,
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Tue Nov 07 02:19:41 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

    import okhttp3.HttpUrl
    import okhttp3.OkHttpClient
    import okhttp3.Request
    import okhttp3.Response
    import okhttp3.internal.EMPTY_HEADERS
    import okhttp3.internal.checkOffsetAndCount
    import okhttp3.internal.discard
    import okhttp3.internal.headersContentLength
    import okhttp3.internal.http.ExchangeCodec
    import okhttp3.internal.http.HTTP_CONTINUE
    import okhttp3.internal.http.RequestLine
    import okhttp3.internal.http.StatusLine
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  6. 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
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/CookiesTest.kt

        val cookie = cookies[0]
        assertThat(cookie.name).isEqualTo("a")
        assertThat(cookie.value).isEqualTo("android")
        assertThat(cookie.comment).isNull()
        assertThat(cookie.commentURL).isNull()
        assertThat(cookie.discard).isFalse()
        assertThat(cookie.maxAge).isGreaterThan(100000000000L)
        assertThat(cookie.path).isEqualTo("/path")
        assertThat(cookie.secure).isTrue()
        assertThat(cookie.version).isEqualTo(0)
      }
    
      @Test
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13K bytes
    - Viewed (0)
  8. internal/ioutil/ioutil_test.go

    	}
    }
    
    func TestCloseOnWriter(t *testing.T) {
    	writer := WriteOnClose(io.Discard)
    	if writer.HasWritten() {
    		t.Error("WriteOnCloser must not be marked as HasWritten")
    	}
    	writer.Write(nil)
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    	}
    
    	writer = WriteOnClose(io.Discard)
    	writer.Close()
    	if !writer.HasWritten() {
    		t.Error("WriteOnCloser must be marked as HasWritten")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed May 22 23:07:14 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  9. src/bufio/bufio.go

    		}
    	}
    	return b.buf[b.r : b.r+n], err
    }
    
    // Discard skips the next n bytes, returning the number of bytes discarded.
    //
    // If Discard skips fewer than n bytes, it also returns an error.
    // If 0 <= n <= b.Buffered(), Discard is guaranteed to succeed without
    // reading from the underlying io.Reader.
    func (b *Reader) Discard(n int) (discarded int, err error) {
    	if n < 0 {
    		return 0, ErrNegativeCount
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Oct 12 14:39:08 UTC 2023
    - 21.8K bytes
    - Viewed (0)
  10. internal/hash/reader_test.go

    	if err != nil {
    		t.Fatal(err)
    	}
    	_, err = io.Copy(io.Discard, r)
    	if err != nil {
    		t.Fatal(err)
    	}
    	md5sum := r.MD5Current()
    	if hex.EncodeToString(md5sum) != "e2fc714c4727ee9395f324cd2e7f331f" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 18 17:00:54 UTC 2023
    - 10.3K bytes
    - Viewed (0)
Back to top