- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 134 for dispatchTo (0.4 sec)
-
pom.xml
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 09:13:34 UTC 2024 - 33.9K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/MockWebServerTest.kt
val connection = server.url("/").toUrl().openConnection() as HttpURLConnection connection.setReadTimeout(500) try { connection.getResponseCode() fail<Any>() } catch (expected: SocketTimeoutException) { } // Shutting down the server should unblock the dispatcher. server.shutdown() } @Test
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 21.9K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/DefaultArtifactDescriptorReader.java
event.setTrace(trace); event.setArtifact(artifact); event.setException(exception); repositoryEventDispatcher.dispatch(event.build()); } private void invalidDescriptor( RepositorySystemSession session, RequestTrace trace, Artifact artifact, Exception exception) {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Jun 10 11:04:53 UTC 2024 - 15.8K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
* New: `Headers.toMultimap()`. * New: `RequestBody.create(MediaType, ByteString)`. * New: `ConnectionSpec.isCompatible(SSLSocket)`. * New: `Dispatcher.getQueuedCallCount()` and `Dispatcher.getRunningCallCount()`. These can be useful in diagnostics. * Fix: OkHttp no longer shares timeouts between pooled connections. This was causing some applications to crash when connections were reused.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/ProviderConnection.java
this.delegate = delegate; } @Override public void dispatch(Object message) { synchronized (this) { delegate.dispatch(message); } } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 05:33:15 UTC 2024 - 30.5K bytes - Viewed (0) -
maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/DefaultVersionRangeResolver.java
event.setTrace(trace); event.setMetadata(metadata); event.setException(exception); event.setRepository(repository); repositoryEventDispatcher.dispatch(event.build()); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 10.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/RetryConditions.groovy
&& daemon.logContains('java.lang.NullPointerException') && daemon.logContains('org.gradle.launcher.daemon.server.exec.LogToClient')) { println "Retrying test because the dispatcher was not ready for receiving a log event. Check log of daemon with PID ${daemon.context.pid}." return cleanProjectDir(specification) } } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 10.7K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/DefaultVersionRangeResolver.java
event.setTrace(trace); event.setMetadata(metadata); event.setException(exception); event.setRepository(repository); repositoryEventDispatcher.dispatch(event.build()); }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Fri Apr 12 10:50:18 UTC 2024 - 10K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
sendTestRequest(twitterRequest) Thread.sleep(1000) sendTestRequest(googleRequest) Thread.sleep(2000) } } finally { client.connectionPool.evictAll() client.dispatcher.executorService.shutdownNow() if (launch == CommandLine) { process?.destroyForcibly() } } } private fun sendTestRequest(request: Request) { try {
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
platforms/software/testing-base-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/worker/TestWorker.java
import org.gradle.internal.concurrent.DefaultExecutorFactory; import org.gradle.internal.concurrent.ExecutorFactory; import org.gradle.internal.concurrent.Stoppable; import org.gradle.internal.dispatch.ContextClassLoaderProxy; import org.gradle.internal.id.CompositeIdGenerator; import org.gradle.internal.id.IdGenerator; import org.gradle.internal.id.LongIdGenerator; import org.gradle.internal.remote.ObjectConnection;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 15:59:04 UTC 2024 - 10K bytes - Viewed (0)