- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for NewClient (0.2 sec)
-
okhttp/src/test/java/okhttp3/OkHttpClientTest.kt
builder.protocols(listOf(Protocol.HTTP_1_0, Protocol.HTTP_1_1)) } } @Test fun certificatePinnerEquality() { val clientA = clientTestRule.newClient() val clientB = clientTestRule.newClient() assertThat(clientB.certificatePinner).isEqualTo(clientA.certificatePinner) } @Test fun nullInterceptorInList() { val builder = OkHttpClient.Builder()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Mar 31 17:16:15 GMT 2024 - 13.2K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt
import org.junit.jupiter.api.extension.ExtensionContext /** * Apply this rule to all tests. It adds additional checks for leaked resources and uncaught * exceptions. * * Use [newClient] as a factory for a OkHttpClient instances. These instances are specifically * configured for testing. */ class OkHttpClientTestRule : BeforeEachCallback, AfterEachCallback {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
common/config/.golangci.yml
- linters: - staticcheck text: 'SA1019: grpc.Dial is deprecated: use NewClient instead' - linters: - staticcheck text: 'SA1019: grpc.DialContext is deprecated: use NewClient instead' # Independently from option `exclude` we use default exclude patterns, # it can be disabled by this option. To list all
Others - Registered: Wed May 01 22:53:12 GMT 2024 - Last Modified: Mon Apr 22 19:22:39 GMT 2024 - 11K bytes - Viewed (0) -
internal/rest/client.go
} return resp.Body, nil } // Close closes all idle connections of the underlying http client func (c *Client) Close() { atomic.StoreInt32(&c.connected, closed) } // NewClient - returns new REST client. func NewClient(uu *url.URL, tr http.RoundTripper, newAuthToken func(aud string) string) *Client { connected := int32(online) urlStr := uu.String() u, err := url.Parse(urlStr) if err != nil {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionReuseTest.kt
private lateinit var server: MockWebServer private val handshakeCertificates = platform.localhostHandshakeCertificates() private var client: OkHttpClient = clientTestRule.newClient() @BeforeEach fun setUp(server: MockWebServer) { this.server = server } @Test fun connectionsAreReused() { server.enqueue(MockResponse(body = "a"))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 12.3K bytes - Viewed (0) -
cmd/peer-rest-client.go
} serverURL := &url.URL{ Scheme: scheme, Host: peer.String(), Path: peerRESTPath, } restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken()) // Use a separate client to avoid recursive calls. healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken()) healthClient.NoMetrics = true // Construct a new health function.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 25.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
import org.junit.jupiter.api.extension.RegisterExtension @Timeout(30) @Tag("Slow") class WholeOperationTimeoutTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val client = clientTestRule.newClient() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server } @Test fun defaultConfigIsNoTimeout() { val request =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CookiesTest.kt
@Timeout(30) class CookiesTest { @RegisterExtension val clientTestRule = OkHttpClientTestRule() private lateinit var server: MockWebServer private var client = clientTestRule.newClient() @BeforeEach fun setUp(server: MockWebServer) { this.server = server } @Test fun testNetscapeResponse() { val cookieManager = CookieManager(null, CookiePolicy.ACCEPT_ORIGINAL_SERVER)
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 13K bytes - Viewed (0) -
cmd/storage-rest-client.go
Host: endpoint.Host, Path: path.Join(storageRESTPrefix, endpoint.Path, storageRESTVersion), } restClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken()) if healthCheck { // Use a separate client to avoid recursive calls. healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken()) healthClient.NoMetrics = true restClient.HealthCheckFn = func() bool {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 26.1K bytes - Viewed (0) -
internal/dsync/dsync_test.go
func TestMain(m *testing.M) { startLockServers() // Initialize locker clients for dsync. var clnts []NetLocker for i := 0; i < len(nodes); i++ { clnts = append(clnts, newClient(nodes[i].URL)) } ds = &Dsync{ GetLockers: func() ([]NetLocker, string) { return clnts, uuid.New().String() }, Timeouts: Timeouts{ Acquire: testDrwMutexAcquireTimeout,
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0)