- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 412 for dispatchTo (0.14 sec)
-
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/remote/internal/hub/queue/QueueInitializerTest.groovy
package org.gradle.internal.remote.internal.hub.queue import org.gradle.internal.dispatch.Dispatch import org.gradle.internal.remote.internal.hub.protocol.EndOfStream import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage class QueueInitializerTest extends AbstractQueueTest { final QueueInitializer initializer = new QueueInitializer() final Dispatch<InterHubMessage> queue = Mock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
} func NewPolicyTestContext[P, B runtime.Object, E Evaluator]( newPolicyAccessor func(P) PolicyAccessor, newBindingAccessor func(B) BindingAccessor, compileFunc func(P) E, dispatcher dispatcherFactory[PolicyHook[P, B, E]], initialObjects []runtime.Object, paramMappings []meta.RESTMapping, ) (*PolicyTestContext[P, B, E], func(), error) { var Pexample P var Bexample B
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/NativeImageTestsAccessors.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal import okhttp3.Cache import okhttp3.Dispatcher import okhttp3.Response import okhttp3.internal.connection.Exchange import okhttp3.internal.connection.RealCall import okhttp3.internal.connection.RealConnection import okio.FileSystem import okio.Path
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 1.3K bytes - Viewed (0) -
platforms/ide/tooling-api-builders/src/main/java/org/gradle/tooling/internal/provider/runner/ProgressEventConsumer.java
delegate.dispatch(event); startedIds.add(event.getDescriptor().getId()); } void finished(InternalOperationFinishedProgressEvent event) { startedIds.remove(event.getDescriptor().getId()); delegate.dispatch(event); } void progress(InternalProgressEvent event) { delegate.dispatch(event); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Dec 14 07:09:35 UTC 2023 - 2.3K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/EndPointQueue.java
import org.gradle.internal.UncheckedException; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.remote.internal.hub.protocol.InterHubMessage; import java.util.ArrayList; import java.util.Collection; import java.util.List; import java.util.concurrent.locks.Condition; public class EndPointQueue implements Dispatch<InterHubMessage> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.9K bytes - Viewed (0) -
okhttp/src/test/java/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"))
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Wed Apr 10 19:46:48 UTC 2024 - 142.5K bytes - Viewed (2) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/ReportStatusDispatcher.java
private static final Logger LOGGER = Logging.getLogger(ReportStatusDispatcher.class); public Status dispatch(Connection<Message> connection, Command statusCommand) { Status returnedStatus = null; Throwable failure = null; try { connection.dispatch(statusCommand); Result result = (Result) connection.receive(); if (result instanceof Failure) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2K bytes - Viewed (0) -
container-tests/src/test/java/okhttp3/containers/BasicLoomTest.kt
fun setUp() { platform.assumeLoom() assertThat(System.getProperty("jdk.tracePinnedThreads")).isNotEmpty() client = OkHttpClient.Builder() .trustMockServer() .dispatcher(Dispatcher(newVirtualThreadPerTaskExecutor())) .build() executor = newVirtualThreadPerTaskExecutor() // Capture non-deterministic but probable sysout warnings of pinned threads
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 06 11:15:46 UTC 2024 - 3.7K bytes - Viewed (0) -
platforms/ide/tooling-api/src/crossVersionTest/groovy/org/gradle/integtests/tooling/fixture/CrossVersionToolingApiSpecificationRetryTest.groovy
throwWhen(new IOException("Could not dispatch a message to the daemon.", new IOException("An existing connection was forcibly closed by the remote host")), iteration == 1) then: IOException ioe = thrown() ioe.message == "Could not dispatch a message to the daemon." } private static void throwWhen(Throwable throwable, boolean condition) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jun 10 06:17:20 UTC 2024 - 5.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/initialization/BuildEventConsumer.java
import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.service.scopes.Scope; import org.gradle.internal.service.scopes.ServiceScope; /** * A consumer for build events provided by the build requester. This can be used to forward events to the build requester. */ @ServiceScope(Scope.BuildSession.class) public interface BuildEventConsumer extends Dispatch<Object> {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 05 08:55:56 UTC 2024 - 1K bytes - Viewed (0)