Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 157 for requester (0.05 seconds)

  1. internal/grid/handlers.go

    			r := RemoteErr(err.Error())
    			return nil, &r
    		}
    		return payload, nil
    	}, subroute...)
    }
    
    // Requester is able to send requests to a remote.
    type Requester interface {
    	Request(ctx context.Context, h HandlerID, req []byte) ([]byte, error)
    }
    
    // Call the remote with the request and return the response.
    // The response should be returned with PutResponse when no error.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 27.7K bytes
    - Click Count (0)
  2. internal/grid/muxclient.go

    	m.singleResp = false
    	m.RecvSeq = m.SendSeq // Sync
    	if cap(requests) > 0 {
    		m.outBlock = make(chan struct{}, cap(requests))
    	}
    	msg := message{
    		Op:         OpConnectMux,
    		Handler:    h,
    		Payload:    payload,
    		DeadlineMS: uint32(m.deadline.Milliseconds()),
    	}
    	msg.setZeroPayloadFlag()
    	if requests == nil {
    		msg.Flags |= FlagEOF
    	}
    	if m.subroute != nil {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  3. docs/en/docs/img/sponsors/requestly.png

    requestly.png...
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Sun Oct 19 19:12:22 GMT 2025
    - 17.9K bytes
    - Click Count (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Request.kt

          this.method = "GET"
          this.headers = Headers.Builder()
        }
    
        internal constructor(request: Request) {
          this.url = request.url
          this.method = request.method
          this.body = request.body
          this.tags = request.tags
          this.headers = request.headers.newBuilder()
          this.cacheUrlOverride = request.cacheUrlOverride
        }
    
        open fun url(url: HttpUrl): Builder =
          apply {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Thu Oct 30 13:46:58 GMT 2025
    - 14.7K bytes
    - Click Count (1)
  5. cmd/sts-datatypes.go

    }
    
    // AssumeRoleResponse contains the result of successful AssumeRole request.
    type AssumeRoleResponse struct {
    	XMLName xml.Name `xml:"https://sts.amazonaws.com/doc/2011-06-15/ AssumeRoleResponse" json:"-"`
    
    	Result           AssumeRoleResult `xml:"AssumeRoleResult"`
    	ResponseMetadata struct {
    		RequestID string `xml:"RequestId,omitempty"`
    	} `xml:"ResponseMetadata,omitempty"`
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri May 27 00:58:09 GMT 2022
    - 9.9K bytes
    - Click Count (0)
  6. src/test/java/jcifs/internal/smb2/Smb2EchoRequestTest.java

            void testMultipleRequests() {
                Smb2EchoRequest request1 = new Smb2EchoRequest(mockConfig);
                Smb2EchoRequest request2 = new Smb2EchoRequest(mockConfig);
    
                // Both should have same properties
                assertEquals(request1.getCommand(), request2.getCommand());
                assertEquals(request1.size(), request2.size());
    
                // But be different objects
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 11.3K bytes
    - Click Count (0)
  7. src/test/java/org/codelibs/curl/CurlTest.java

            // ## Act ##
            final CurlRequest request1 = Curl.get("http://example.com");
            final CurlRequest request2 = Curl.get("http://example.com");
    
            // ## Assert ##
            assertNotNull(request1);
            assertNotNull(request2);
            assertTrue("Factory methods should return different instances", request1 != request2);
        }
    
        @Test
    Created: Thu Apr 02 15:34:12 GMT 2026
    - Last Modified: Thu Nov 20 13:34:13 GMT 2025
    - 16.3K bytes
    - Click Count (0)
  8. okhttp-dnsoverhttps/src/test/java/okhttp3/dnsoverhttps/DnsOverHttpsTest.kt

        assertThat(result).contains(address("2a03:2880:f029:11:face:b00c:0:2"))
        val request1 = server.takeRequest()
        assertThat(request1.method).isEqualTo("GET")
        val request2 = server.takeRequest()
        assertThat(request2.method).isEqualTo("GET")
        assertThat(listOf(request1.url.encodedQuery, request2.url.encodedQuery))
          .containsExactlyInAnyOrder(
            "ct&dns=AAABAAABAAAAAAAABmdvb2dsZQNjb20AAAEAAQ",
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/fscc/FsctlPipeWaitRequestTest.java

            // Test without timeout
            FsctlPipeWaitRequest request1 = new FsctlPipeWaitRequest(pipeName);
            byte[] buffer1 = new byte[200];
            int encoded1 = request1.encode(buffer1, 0);
            assertEquals(request1.size(), encoded1);
    
            // Test with timeout
            FsctlPipeWaitRequest request2 = new FsctlPipeWaitRequest(pipeName, 5000L);
            byte[] buffer2 = new byte[200];
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 13.1K bytes
    - Click Count (0)
  10. cmd/sts-handlers.go

    	// use that and validate the authentication request. If not, we assume this
    	// is an STS request for a claim based IDP (if one is present) and set
    	// roleArn = openid.DummyRoleARN.
    	//
    	// Currently, we do not support multiple claim based IDPs, as there is no
    	// defined parameter to disambiguate the intended IDP in this STS request.
    	roleArn := openid.DummyRoleARN
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 36.6K bytes
    - Click Count (0)
Back to Top