Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 14 for newRequest (0.11 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        server.enqueue(response)
        assertContent("ABCDEFGHIJKLMNOPQR", getResponse(newRequest("/foo")))
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(0)
        assertContent("ABCDEFGHIJKLMNOPQR", getResponse(newRequest("/bar?baz=quux")))
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(1)
        assertContent("ABCDEFGHIJKLMNOPQR", getResponse(newRequest("/z")))
        assertThat(server.takeRequest().exchangeIndex).isEqualTo(2)
      }
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/DispatcherTest.kt

        dispatcher.maxRequests = 2
        client.newCall(newRequest("http://a/1")).enqueue(callback)
        client.newCall(newRequest("http://b/1")).enqueue(callback)
        client.newCall(newRequest("http://c/1")).enqueue(callback)
        client.newCall(newRequest("http://a/2")).enqueue(callback)
        client.newCall(newRequest("http://b/2")).enqueue(callback)
    
        val dispatcherQueueStartC1 = eventRecorder.removeUpToEvent<DispatcherQueueStart>()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  3. src/test/java/jcifs/internal/smb2/RequestWithFileIdTest.java

            // Since we can't directly verify the internal state, we create a new request to test
            Smb2CloseRequest newRequest = new Smb2CloseRequest(mockConfig, testFileId);
            assertNotNull(newRequest, "Should create request with new file ID");
        }
    
        @Test
        @DisplayName("Should handle null file ID")
        void testSetNullFileId() {
            // Given
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  4. internal/config/policy/opa/config.go

    	Transport   http.RoundTripper     `json:"-"`
    	CloseRespFn func(r io.ReadCloser) `json:"-"`
    }
    
    // Validate - validate opa configuration params.
    func (a *Args) Validate() error {
    	req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte("")))
    	if err != nil {
    		return err
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    	if a.AuthToken != "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  5. internal/config/subnet/subnet.go

    	part, e := writer.CreateFormFile("file", filename)
    	if e != nil {
    		return "", e
    	}
    
    	if _, e = part.Write(payload); e != nil {
    		return "", e
    	}
    	writer.Close()
    
    	r, e := http.NewRequest(http.MethodPost, reqURL, &body)
    	if e != nil {
    		return "", e
    	}
    	r.Header.Add("Content-Type", writer.FormDataContentType())
    
    	return c.submitPost(r)
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.9K bytes
    - Click Count (0)
  6. internal/config/policy/plugin/config.go

    	Transport   http.RoundTripper     `json:"-"`
    	CloseRespFn func(r io.ReadCloser) `json:"-"`
    }
    
    // Validate - validate opa configuration params.
    func (a *Args) Validate() error {
    	req, err := http.NewRequest(http.MethodPost, a.URL.String(), bytes.NewReader([]byte("")))
    	if err != nil {
    		return err
    	}
    
    	req.Header.Set("Content-Type", "application/json")
    	if a.AuthToken != "" {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.8K bytes
    - Click Count (0)
  7. cmd/signature-v2_test.go

    		query := url.Values{}
    		for key, value := range testCase.queryParams {
    			query.Set(key, value)
    		}
    		// Create a request to use.
    		req, err := http.NewRequest(http.MethodGet, "http://host/a/b?"+query.Encode(), nil)
    		if err != nil {
    			t.Errorf("(%d) failed to create http.Request, got %v", i, err)
    		}
    		if testCase.expected != ErrNone {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8K bytes
    - Click Count (0)
  8. cmd/utils_test.go

    		if !testCase.shouldPass && err == nil {
    			t.Errorf("Test %d: expected to fail but passed.", i+1)
    		}
    	}
    }
    
    // Testing dumping request function.
    func TestDumpRequest(t *testing.T) {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  9. cmd/update.go

    	}
    	uaAppend(")", "")
    
    	return strings.Join(userAgentParts, "")
    }
    
    func downloadReleaseURL(u *url.URL, timeout time.Duration, mode string) (content string, err error) {
    	req, err := http.NewRequest(http.MethodGet, u.String(), nil)
    	if err != nil {
    		return content, AdminError{
    			Code:       AdminUpdateUnexpectedFailure,
    			Message:    err.Error(),
    			StatusCode: http.StatusInternalServerError,
    		}
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  10. internal/config/identity/openid/jwt.go

    }
    
    func parseDiscoveryDoc(u *xnet.URL, transport http.RoundTripper, closeRespFn func(io.ReadCloser)) (DiscoveryDoc, error) {
    	d := DiscoveryDoc{}
    	req, err := http.NewRequest(http.MethodGet, u.String(), nil)
    	if err != nil {
    		return d, err
    	}
    	clnt := http.Client{
    		Transport: transport,
    	}
    	resp, err := clnt.Do(req)
    	if err != nil {
    		return d, err
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.4K bytes
    - Click Count (0)
Back to Top