- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for newClient (0.28 sec)
-
native-image-tests/src/main/kotlin/okhttp3/SampleTest.kt
server.enqueue(MockResponse(body = "abc")) val client = clientRule.newClient() client.newCall(Request(url = server.url("/"))).execute().use { assertThat(it.body.string()).isEqualTo("abc") } } @Test fun testExternalSite() { val client = clientRule.newClient() client.newCall(Request(url = "https://google.com/robots.txt".toHttpUrl())).execute().use {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.8K bytes - Viewed (0) -
src/net/rpc/jsonrpc/client.go
return nil } return json.Unmarshal(*c.resp.Result, x) } func (c *clientCodec) Close() error { return c.c.Close() } // NewClient returns a new [rpc.Client] to handle requests to the // set of services at the other end of the connection. func NewClient(conn io.ReadWriteCloser) *rpc.Client { return rpc.NewClientWithCodec(NewClientCodec(conn)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 3K bytes - Viewed (0) -
src/net/rpc/client.go
// concurrent reads or concurrent writes. func NewClient(conn io.ReadWriteCloser) *Client { encBuf := bufio.NewWriter(conn) client := &gobClientCodec{conn, gob.NewDecoder(conn), gob.NewEncoder(encBuf), encBuf} return NewClientWithCodec(client) } // NewClientWithCodec is like [NewClient] but uses the specified // codec to encode requests and decode responses.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 9K bytes - Viewed (0) -
mockwebserver-junit5/src/test/java/mockwebserver3/junit5/internal/ExtensionLifecycleTest.kt
assertThat(server).isSameInstanceAs(instanceServer) clientTestRule.newClient().newCall(Request(server.url("/"))).execute().use { assertThat(it.code).isEqualTo(200) } } @Test fun testClient2(server: MockWebServer) { assertThat(server).isSameInstanceAs(instanceServer) clientTestRule.newClient().newCall(Request(server.url("/"))).execute().use { assertThat(it.code).isEqualTo(200)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 11 12:12:36 UTC 2024 - 3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/BouncyCastleTest.kt
class BouncyCastleTest { @JvmField @RegisterExtension var platform = PlatformRule() @JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() var client = clientTestRule.newClient() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server OkHttpDebugLogging.enable("org.bouncycastle.jsse") platform.assumeBouncyCastle()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/CorrettoTest.kt
class CorrettoTest { @JvmField @RegisterExtension val platform = PlatformRule() @JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val client = clientTestRule.newClient() @BeforeEach fun setUp() { platform.assumeCorretto() } @Test @Disabled fun testMozilla() { assumeNetwork()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K bytes - Viewed (0) -
cni/pkg/repair/repair.go
func clientSetup() (kube.Client, error) { config, err := kube.DefaultRestConfig("", "") if err != nil { return nil, err } return kube.NewClient(kube.NewClientConfigForRestConfig(config), "")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 1.5K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourcesHttpTest.kt
private lateinit var server: MockWebServer @RegisterExtension val clientTestRule = OkHttpClientTestRule() private val listener = EventSourceRecorder() private val client = clientTestRule.newClient() @BeforeEach fun before(server: MockWebServer) { this.server = server } @AfterEach fun after() { listener.assertExhausted() } @Test fun processResponse() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 2.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/connection/RetryConnectionTest.kt
private val retryableException = SSLHandshakeException("Simulated handshake exception") @RegisterExtension val clientTestRule = OkHttpClientTestRule() private var client = clientTestRule.newClient() @AfterEach internal fun tearDown() { factory.close() } @Test fun nonRetryableIOException() { val exception = IOException("Non-handshake exception")
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/OpenJSSETest.kt
class OpenJSSETest { @JvmField @RegisterExtension var platform = PlatformRule() @JvmField @RegisterExtension val clientTestRule = OkHttpClientTestRule() var client = clientTestRule.newClient() private lateinit var server: MockWebServer @BeforeEach fun setUp(server: MockWebServer) { this.server = server platform.assumeOpenJSSE() } @Test fun testTlsv13Works() {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 3.7K bytes - Viewed (0)