- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for dispatcher (0.32 sec)
-
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
this.taskRunner = okHttpClient.taskRunner } /** * Sets the dispatcher used to set policy and execute asynchronous requests. Must not be null. */ fun dispatcher(dispatcher: Dispatcher) = apply { this.dispatcher = dispatcher } /** * Sets the connection pool used to recycle HTTP and HTTPS connections. *
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
// We use a re-entrant dispatcher to initiate one HTTPS connection while the other is in flight. server.dispatcher = object : Dispatcher() { var requestCount = 0 override fun dispatch(request: RecordedRequest): MockResponse { val result = queueDispatcher.dispatch(request) requestCount++ if (requestCount == 1) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
okhttp/api/okhttp.api
public final fun -deprecated_connectionSpecs ()Ljava/util/List; public final fun -deprecated_cookieJar ()Lokhttp3/CookieJar; public final fun -deprecated_dispatcher ()Lokhttp3/Dispatcher; public final fun -deprecated_dns ()Lokhttp3/Dns; public final fun -deprecated_eventListenerFactory ()Lokhttp3/EventListener$Factory; public final fun -deprecated_followRedirects ()Z
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 15 13:41:01 GMT 2024 - 70.2K bytes - Viewed (0) -
tensorflow/BUILD
"//tensorflow/core/common_runtime/eager:tensor_handle", "//tensorflow/core/config:flag_defs", "//tensorflow/core/config:flags", "//tensorflow/core/data/service:dispatcher_client", "//tensorflow/core/data/service:grpc_util", "//tensorflow/core/data/service:py_utils", "//tensorflow/core/data/service:server_lib", "//tensorflow/core/debug",
Plain Text - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Tue Apr 09 18:15:11 GMT 2024 - 53.4K bytes - Viewed (8) -
analysis/analysis-api-fir/src/org/jetbrains/kotlin/analysis/api/fir/components/KtFirCallResolver.kt
when (explicitReceiverKind) { ExplicitReceiverKind.DISPATCH_RECEIVER -> { checkWithAttachment( dispatchReceiver != null, { "Dispatch receiver must be not null if explicitReceiverKind is DISPATCH_RECEIVER" } ) { withPsiEntry("explicitReceiverPsi", explicitReceiverPsi)
Plain Text - Registered: Fri Apr 26 08:18:10 GMT 2024 - Last Modified: Thu Apr 25 18:05:58 GMT 2024 - 70.8K bytes - Viewed (1) -
configure.py
# Windows. environ_cp['TF_DOWNLOAD_CLANG'] = '0' environ_cp['TF_NEED_MPI'] = '0' if is_macos(): environ_cp['TF_NEED_TENSORRT'] = '0' if is_ppc64le(): # Enable MMA Dynamic Dispatch support if 'gcc' and if linker >= 2.35 gcc_env = get_gcc_compiler(environ_cp) if gcc_env is not None: # Use gold linker if 'gcc' and if 'ppc64le'
Python - Registered: Tue Apr 30 12:39:09 GMT 2024 - Last Modified: Mon Apr 15 18:25:36 GMT 2024 - 53.8K bytes - Viewed (1) -
cmd/iam.go
} func (sys *IAMSys) periodicRoutines(ctx context.Context, baseInterval time.Duration) { // Watch for IAM config changes for iamStorageWatcher. watcher, isWatcher := sys.store.IAMStorageAPI.(iamStorageWatcher) if isWatcher { go func() { ch := watcher.watch(ctx, iamConfigPrefix) for event := range ch { if err := sys.loadWatchedEvent(ctx, event); err != nil { // we simply log errors
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1)