Search Options

Results per page
Sort
Preferred Languages
Advance

Results 621 - 630 of 660 for buffered (0.15 sec)

  1. internal/rest/client.go

    		ProtoMajor: 1,
    		ProtoMinor: 1,
    		Header:     make(http.Header),
    		Body:       rc,
    		Host:       u.Host,
    	}
    	req = req.WithContext(ctx)
    	if body != nil {
    		switch v := body.(type) {
    		case *bytes.Buffer:
    			req.ContentLength = int64(v.Len())
    			buf := v.Bytes()
    			req.GetBody = func() (io.ReadCloser, error) {
    				r := bytes.NewReader(buf)
    				return io.NopCloser(r), nil
    			}
    		case *bytes.Reader:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  2. src/bytes/bytes_test.go

    		if err := recover(); err == nil {
    			t.Fatal("Grow(-1) should have panicked")
    		}
    	}()
    	var b Buffer
    	b.Grow(-1)
    }
    
    func TestBufferTruncateNegative(t *testing.T) {
    	defer func() {
    		if err := recover(); err == nil {
    			t.Fatal("Truncate(-1) should have panicked")
    		}
    	}()
    	var b Buffer
    	b.Truncate(-1)
    }
    
    func TestBufferTruncateOutOfRange(t *testing.T) {
    	defer func() {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Aug 19 19:09:04 UTC 2024
    - 61.2K bytes
    - Viewed (0)
  3. api/go1.6.txt

    pkg archive/zip, method (*Reader) RegisterDecompressor(uint16, Decompressor)
    pkg archive/zip, method (*Writer) RegisterCompressor(uint16, Compressor)
    pkg bufio, method (*Scanner) Buffer([]uint8, int)
    pkg bufio, var ErrFinalToken error
    pkg crypto/tls, const TLS_RSA_WITH_AES_128_GCM_SHA256 = 156
    pkg crypto/tls, const TLS_RSA_WITH_AES_128_GCM_SHA256 uint16
    pkg crypto/tls, const TLS_RSA_WITH_AES_256_GCM_SHA384 = 157
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Wed Jan 13 23:40:13 UTC 2016
    - 12.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/primitives/ImmutableIntArray.java

     *
     * <ul>
     *   <li>Memory footprint has a fixed overhead (about 24 bytes per instance).
     *   <li><i>Some</i> construction use cases force the data to be copied (though several construction
     *       APIs are offered that don't).
     *   <li>Can't be passed directly to methods that expect {@code int[]} (though the most common
     *       utilities do have replacements here).
     *   <li>Dependency on {@code com.google.common} / Guava.
     * </ul>
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  5. licenses/github.com/hashicorp/hcl/LICENSE

         Software. However, You may do so only on Your own behalf, and not on behalf
         of any Contributor. You must make it absolutely clear that any such
         warranty, support, indemnity, or liability obligation is offered by You
         alone, and You hereby agree to indemnify every Contributor for any
         liability incurred by such Contributor as a result of warranty, support,
         indemnity or liability terms You offer. You may include additional
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Sat Oct 26 02:47:39 UTC 2019
    - 15.6K bytes
    - Viewed (0)
  6. istioctl/pkg/validate/validate_test.go

    			})
    			validateCmd := NewValidateCommand(ctx)
    			validateCmd.SilenceUsage = true
    			validateCmd.SetArgs(c.args)
    
    			// capture output to keep test logs clean
    			var out bytes.Buffer
    			validateCmd.SetOut(&out)
    			validateCmd.SetErr(&out)
    
    			err := validateCmd.Execute()
    			if (err != nil) != c.wantError {
    				t.Errorf("unexpected validate return status: got %v want %v: \nerr=%v",
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Aug 02 16:18:14 UTC 2024
    - 21.4K bytes
    - Viewed (0)
  7. okhttp/src/test/java/okhttp3/EventListenerTest.kt

    import okhttp3.internal.connection.RealConnectionPool.Companion.get
    import okhttp3.logging.HttpLoggingInterceptor
    import okhttp3.testing.Flaky
    import okhttp3.testing.PlatformRule
    import okio.Buffer
    import okio.BufferedSink
    import org.hamcrest.BaseMatcher
    import org.hamcrest.CoreMatchers
    import org.hamcrest.Description
    import org.hamcrest.Matcher
    import org.hamcrest.MatcherAssert
    import org.junit.Assume
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 56.9K bytes
    - Viewed (2)
  8. android/guava/src/com/google/common/primitives/ImmutableDoubleArray.java

     *
     * <ul>
     *   <li>Memory footprint has a fixed overhead (about 24 bytes per instance).
     *   <li><i>Some</i> construction use cases force the data to be copied (though several construction
     *       APIs are offered that don't).
     *   <li>Can't be passed directly to methods that expect {@code double[]} (though the most common
     *       utilities do have replacements here).
     *   <li>Dependency on {@code com.google.common} / Guava.
     * </ul>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 18:05:56 UTC 2024
    - 23K bytes
    - Viewed (0)
  9. tensorflow/c/c_api.cc

        result = session->Run(run_options_proto, input_pairs, output_tensor_names,
                              target_oper_names, &outputs, &run_metadata_proto);
    
        // Serialize back to upstream client, who now owns the new buffer
        if (run_metadata != nullptr) {
          status->status = MessageToBuffer(run_metadata_proto, run_metadata);
          if (!status->status.ok()) return;
        }
      } else {
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 16:27:48 UTC 2024
    - 102.3K bytes
    - Viewed (0)
  10. cmd/metacache-stream_test.go

    		}
    		if gotObj.name != want {
    			t.Errorf("entry %d, want %q, got %q", i, want, gotObj.name)
    		}
    	}
    }
    
    func Test_newMetacacheStream(t *testing.T) {
    	r := loadMetacacheSample(t)
    	var buf bytes.Buffer
    	w := newMetacacheWriter(&buf, 1<<20)
    	defer w.Close()
    	err := r.readFn(func(object metaCacheEntry) bool {
    		err := w.write(object)
    		if err != nil {
    			t.Fatal(err)
    		}
    		return true
    	})
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 15K bytes
    - Viewed (0)
Back to top