- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,395 for calls (0.17 sec)
-
docs/features/calls.md
Calls are executed in one of two ways: * **Synchronous:** your thread blocks until the response is readable. * **Asynchronous:** you enqueue the request on any thread, and get [called back](https://square.github.io/okhttp/4.x/okhttp/okhttp3/-callback/) on another thread when the response is readable.
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 3.9K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
std::list<size_t> calls; auto fetcher = [&calls, block_size](const string& filename, size_t offset, size_t n, char* buffer, TF_Status* status) -> int64_t { EXPECT_EQ(n, block_size); EXPECT_FALSE(calls.empty()) << "at offset = " << offset; if (!calls.empty()) { EXPECT_EQ(offset, calls.front()); calls.pop_front(); }
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Fri Oct 15 03:16:57 GMT 2021 - 23.2K bytes - Viewed (0) -
analysis/analysis-api-fe10/src/org/jetbrains/kotlin/analysis/api/descriptors/components/KtFe10CallResolver.kt
import org.jetbrains.kotlin.resolve.calls.CallTransformer import org.jetbrains.kotlin.resolve.calls.components.isVararg import org.jetbrains.kotlin.resolve.calls.context.BasicCallResolutionContext import org.jetbrains.kotlin.resolve.calls.context.CheckArgumentTypesMode import org.jetbrains.kotlin.resolve.calls.context.ContextDependency import org.jetbrains.kotlin.resolve.calls.inference.model.TypeVariableTypeConstructor
Plain Text - Registered: Fri Apr 19 08:18:09 GMT 2024 - Last Modified: Thu Mar 14 06:10:31 GMT 2024 - 36.4K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/expiring_lru_cache_test.cc
TEST(ExpiringLRUCacheTest, LookupOrCompute) { // max_age of 0 means we should always compute. uint64 num_compute_calls = 0; tf_gcs_filesystem::ExpiringLRUCache<int>::ComputeFunc compute_func = [&num_compute_calls](const string& key, int* value, TF_Status* status) { *value = num_compute_calls; num_compute_calls++; return TF_SetStatus(status, TF_OK, ""); };
C++ - Registered: Tue Apr 23 12:39:09 GMT 2024 - Last Modified: Thu Jul 09 19:31:22 GMT 2020 - 7.1K bytes - Viewed (0) -
cmd/lock-rest-client.go
} return ok, err } // RLock calls read lock REST API. func (c *lockRESTClient) RLock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCRLock, &args) } // Lock calls lock REST API. func (c *lockRESTClient) Lock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) { return c.call(ctx, lockRPCLock, &args) } // RUnlock calls read unlock REST API.
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Nov 24 17:07:14 GMT 2023 - 3.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Dispatcher.kt
} /** * Cancel all calls currently enqueued or executing. Includes calls executed both * [synchronously][Call.execute] and [asynchronously][Call.enqueue]. */ @Synchronized fun cancelAll() { for (call in readyAsyncCalls) { call.call.cancel() } for (call in runningAsyncCalls) { call.call.cancel() } for (call in runningSyncCalls) { call.cancel() }
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Wed Apr 17 05:15:48 GMT 2024 - 8.7K bytes - Viewed (0) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/references/KtFirInvokeFunctionReference.kt
*/ package org.jetbrains.kotlin.idea.references import org.jetbrains.kotlin.analysis.api.KtAnalysisSession import org.jetbrains.kotlin.analysis.api.calls.KtSimpleFunctionCall import org.jetbrains.kotlin.analysis.api.calls.calls import org.jetbrains.kotlin.analysis.api.calls.symbol import org.jetbrains.kotlin.analysis.api.symbols.KtFunctionSymbol import org.jetbrains.kotlin.analysis.api.symbols.KtSymbol
Plain Text - Registered: Fri Mar 22 08:18:09 GMT 2024 - Last Modified: Wed Jun 21 20:40:22 GMT 2023 - 1.2K bytes - Viewed (0) -
maven-core/src/test/java/org/apache/maven/classrealm/DefaultClassRealmManagerTest.java
verifier.verify(logger, calls(1)).debug("Importing foreign packages into class realm {}", "maven.api"); verifier.verify(logger, calls(1)).debug(" Imported: {} < {}", "group1:artifact1", "test"); verifier.verify(logger, calls(1)).debug(" Excluded: {}", "group1:artifact2:ext:classifier1:null"); verifier.verify(logger, calls(1))
Java - Registered: Sun Apr 21 03:35:09 GMT 2024 - Last Modified: Wed Jan 10 12:53:42 GMT 2024 - 7.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingExecutor.kt
} fun finishJob(url: String) { val i = calls.iterator() while (i.hasNext()) { val call = i.next() if (call.request.url.toString() == url) { i.remove() dispatcherTest.dispatcher.finishedAccessor(call) return } } throw AssertionError("No such job: $url") } override fun shutdown() { shutdown = true } override fun shutdownNow(): List<Runnable> {
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
docs/features/events.md
} @Override public void callStart(Call call) { printEvent("callStart"); } @Override public void callEnd(Call call) { printEvent("callEnd"); } @Override public void dnsStart(Call call, String domainName) { printEvent("dnsStart"); } @Override public void dnsEnd(Call call, String domainName, List<InetAddress> inetAddressList) { printEvent("dnsEnd");
Plain Text - Registered: Fri Apr 19 11:42:09 GMT 2024 - Last Modified: Sun Feb 06 02:19:09 GMT 2022 - 7.7K bytes - Viewed (0)