- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 12 for Dispatcher (0.08 seconds)
-
src/main/webapp/WEB-INF/web.xml
<url-pattern>/*</url-pattern> <dispatcher>REQUEST</dispatcher> <dispatcher>FORWARD</dispatcher><!-- TODO --> </filter-mapping> <filter-mapping> <filter-name>lastaPrepareFilter</filter-name> <url-pattern>/*</url-pattern> <dispatcher>REQUEST</dispatcher> <dispatcher>FORWARD</dispatcher> <dispatcher>INCLUDE</dispatcher> </filter-mapping> <filter-mapping>Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 09:08:35 GMT 2026 - 8.5K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/KotlinSourceModernTest.kt
} @Test fun dispatcher() { var dispatcher = Dispatcher() dispatcher = Dispatcher(Executors.newCachedThreadPool()) val maxRequests: Int = dispatcher.maxRequests dispatcher.maxRequests = 0 val maxRequestsPerHost: Int = dispatcher.maxRequestsPerHost dispatcher.maxRequestsPerHost = 0 val executorService: ExecutorService = dispatcher.executorServiceCreated: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 49.7K bytes - Click Count (0) -
docs/features/calls.md
calls, you bring your own thread and are responsible for managing how many simultaneous requests you make. Too many simultaneous connections wastes resources; too few harms latency. For asynchronous calls, [`Dispatcher`](https://square.github.io/okhttp/5.x/okhttp/okhttp3/-dispatcher/) implements policy for maximum simultaneous requests. You can set maximums per-webserver (default is 5), and overall (default is 64)....
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 3.9K bytes - Click Count (0) -
samples/static-server/src/main/java/okhttp3/sample/SampleServer.java
import javax.net.ssl.SSLContext; import javax.net.ssl.TrustManagerFactory; import okhttp3.mockwebserver.Dispatcher; import okhttp3.mockwebserver.MockResponse; import okhttp3.mockwebserver.MockWebServer; import okhttp3.mockwebserver.RecordedRequest; import okio.Buffer; import okio.Okio; public class SampleServer extends Dispatcher { private final SSLContext sslContext; private final String root; private final int port;Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Mar 11 02:37:00 GMT 2026 - 5.3K bytes - Click Count (0) -
okhttp/api/jvm/okhttp.api
public fun connectionAcquired (Lokhttp3/Call;Lokhttp3/Connection;)V public fun connectionReleased (Lokhttp3/Call;Lokhttp3/Connection;)V public fun dispatcherQueueEnd (Lokhttp3/Call;Lokhttp3/Dispatcher;)V public fun dispatcherQueueStart (Lokhttp3/Call;Lokhttp3/Dispatcher;)V public fun dnsEnd (Lokhttp3/Call;Ljava/lang/String;Ljava/util/List;)V public fun dnsStart (Lokhttp3/Call;Ljava/lang/String;)V
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 72.3K bytes - Click Count (0) -
okhttp/api/android/okhttp.api
public fun connectionAcquired (Lokhttp3/Call;Lokhttp3/Connection;)V public fun connectionReleased (Lokhttp3/Call;Lokhttp3/Connection;)V public fun dispatcherQueueEnd (Lokhttp3/Call;Lokhttp3/Dispatcher;)V public fun dispatcherQueueStart (Lokhttp3/Call;Lokhttp3/Dispatcher;)V public fun dnsEnd (Lokhttp3/Call;Ljava/lang/String;Ljava/util/List;)V public fun dnsStart (Lokhttp3/Call;Ljava/lang/String;)V
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Mar 10 21:47:20 GMT 2026 - 72.3K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
*/ @Test fun canceledBeforeIOSignalsOnFailure() { // Force requests to be executed serially. val dispatcher = Dispatcher(client.dispatcher.executorService) dispatcher.maxRequests = 1 client = client .newBuilder() .dispatcher(dispatcher) .build() val requestA = Request(server.url("/a")) val requestB = Request(server.url("/b"))
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 146.5K bytes - Click Count (0) -
docs/recipes.md
=== ":material-language-kotlin: Kotlin" ```kotlin
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:01:42 GMT 2026 - 47.8K bytes - Click Count (0) -
RELEASE.md
register a dataset with the tf.data service, and another process to consume data from the dataset. * Adds support for dispatcher fault tolerance. To enable fault tolerance, configure a `work_dir` when running your dispatcher server and set `dispatcher_fault_tolerance=True`. The dispatcher will store its state to `work_dir`, so that on restart it can continue from its previous state after restart.Created: Tue Apr 07 12:39:13 GMT 2026 - Last Modified: Mon Mar 30 18:31:38 GMT 2026 - 746.5K bytes - Click Count (3) -
src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java
try { cleanupExpiredDocuments(); } catch (final Exception e) { logger.debug("Failed to cleanup expired documents in poll.", e); } } /** * Dispatches an event to all registered handlers for the event name. * * @param event the event to dispatch. */ protected void dispatchEvent(final EventInfo event) {Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 33.3K bytes - Click Count (0)