- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,139 for pcall (0.22 sec)
-
android-test-app/src/main/kotlin/okhttp/android/testapp/MainActivity.kt
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 1.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/WholeOperationTimeoutTest.kt
.build() val latch = CountDownLatch(1) val exceptionRef = AtomicReference<Throwable>() val call = client.newCall(request) call.timeout().timeout(250, TimeUnit.MILLISECONDS) call.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) { exceptionRef.set(e) latch.countDown() }
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/CallConnectionUser.kt
call.plansToCancel -= connectPlan } override fun updateRouteDatabaseAfterSuccess(route: Route) { call.client.routeDatabase.connected(route) } override fun connectStart(route: Route) { eventListener.connectStart(call, route.socketAddress, route.proxy) poolConnectionListener.connectStart(route, call) } override fun connectFailed( route: Route, protocol: Protocol?,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Wed Mar 06 17:33:38 GMT 2024 - 3.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ConnectionCoalescingTest.kt
override fun connectionAcquired( call: Call, connection: Connection, ) { // We have the connection and it's in the pool. Let request2 proceed to make a connection. latch2.countDown() } } val request2Listener: EventListener = object : EventListener() { override fun connectStart( call: Call, inetSocketAddress: InetSocketAddress,
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 18.7K bytes - Viewed (0) -
samples/slack/src/main/java/okhttp3/slack/SlackApi.java
.addQueryParameter("redirect_uri", redirectUrl.toString()) .build(); Request request = new Request.Builder() .url(url) .build(); Call call = httpClient.newCall(request); try (Response response = call.execute()) { JsonAdapter<OAuthSession> jsonAdapter = moshi.adapter(OAuthSession.class); return jsonAdapter.fromJson(response.body().source()); } }
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Jul 06 19:30:55 GMT 2018 - 4.4K bytes - Viewed (1) -
samples/guide/src/main/java/okhttp3/recipes/AsynchronousGet.java
.url("http://publicobject.com/helloworld.txt") .build(); client.newCall(request).enqueue(new Callback() { @Override public void onFailure(Call call, IOException e) { e.printStackTrace(); } @Override public void onResponse(Call call, Response response) throws IOException { try (ResponseBody responseBody = response.body()) {
Java - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Sun May 22 01:29:42 GMT 2016 - 1.9K bytes - Viewed (0) -
okhttp-dnsoverhttps/src/main/kotlin/okhttp3/dnsoverhttps/DnsOverHttps.kt
hostname: String, networkRequests: List<Call>, responses: MutableList<InetAddress>, failures: MutableList<Exception>, ) { val latch = CountDownLatch(networkRequests.size) for (call in networkRequests) { call.enqueue( object : Callback { override fun onFailure( call: Call, e: IOException, ) {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Mar 22 07:09:21 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp-coroutines/README.md
OkHttp Coroutines ================= Support for Kotlin clients using coroutines. ```kotlin val call = client.newCall(request) call.executeAsync().use { response -> withContext(Dispatchers.IO) { println(response.body?.string()) } } ``` This is implemented using `suspendCancellableCoroutine` but uses the standard Dispatcher in OkHttp. This means that by default Kotlin's Dispatchers are not used.
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Nov 09 15:47:27 GMT 2023 - 609 bytes - Viewed (0) -
docs/recipes.md
final Call call = client.newCall(request); // Schedule a job to cancel the call in 1 second. executor.schedule(new Runnable() { @Override public void run() { System.out.printf("%.2f Canceling call.%n", (System.nanoTime() - startNanos) / 1e9f); call.cancel(); System.out.printf("%.2f Canceled call.%n", (System.nanoTime() - startNanos) / 1e9f);
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Fri Feb 18 08:52:22 GMT 2022 - 40.2K bytes - Viewed (1) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10CallResolver.kt
} private fun handleAsPropertyRead(context: BindingContext, element: KtElement): KtCallInfo? { val call = element.getResolvedCall(context) ?: return null return call.toPropertyRead(context)?.let { createCallInfo(context, element, it, listOf(call)) } } /** * Handles call expressions like `Foo<Bar>` or `test.Foo<Bar>` in calls like `Foo<Bar>::foo` and `test.Foo<Bar>::foo`. *
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Mar 14 06:10:31 GMT 2024 - 36.4K bytes - Viewed (0)