- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 215 for dispatchTo (0.16 sec)
-
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/event/AnonymousListenerBroadcast.java
*/ package org.gradle.internal.event; import org.gradle.internal.dispatch.Dispatch; import org.gradle.internal.dispatch.MethodInvocation; public class AnonymousListenerBroadcast<T> extends ListenerBroadcast<T> { private final Dispatch<MethodInvocation> forwardingDispatch; public AnonymousListenerBroadcast(Class<T> type, Dispatch<MethodInvocation> forwardingDispatch) { super(type);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/ProxyDispatchAdapter.java
return otherHandler.type.equals(type) && otherHandler.dispatch == dispatch; } if (method.getName().equals("hashCode")) { return dispatch.hashCode(); } if (method.getName().equals("toString")) { return type.getSimpleName() + " broadcast"; } dispatch.dispatch(new MethodInvocation(method, parameters)); return null;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 13:09:37 UTC 2024 - 3.5K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/FailureHandlingDispatch.java
*/ package org.gradle.internal.dispatch; public class FailureHandlingDispatch<T> implements Dispatch<T> { private final Dispatch<? super T> dispatch; private final DispatchFailureHandler<? super T> handler; public FailureHandlingDispatch(Dispatch<? super T> dispatch, DispatchFailureHandler<? super T> handler) { this.dispatch = dispatch; this.handler = handler; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.2K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/internal/daemon/clientinput/StdInStreamTest.groovy
} then: 1 * dispatch.onOutput({ it instanceof ReadStdInEvent }) >> { instant.requested1 } 1 * dispatch.onOutput({ it instanceof ReadStdInEvent }) >> { instant.requested2 } } def "read bytes returns when stream is closed"() { def dispatch = Mock(OutputEventListener) def stream = new StdInStream(dispatch) when: async { start {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 5.2K bytes - Viewed (0) -
maven-settings-builder/src/main/java/org/apache/maven/settings/crypto/MavenSecDispatcherProvider.java
import java.util.Map; import org.sonatype.plexus.components.cipher.PlexusCipher; import org.sonatype.plexus.components.sec.dispatcher.DefaultSecDispatcher; import org.sonatype.plexus.components.sec.dispatcher.PasswordDecryptor; import org.sonatype.plexus.components.sec.dispatcher.SecDispatcher; @Named("maven") @Singleton public final class MavenSecDispatcherProvider implements Provider<SecDispatcher> {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Mon Dec 26 15:12:32 UTC 2022 - 1.7K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/test/groovy/org/gradle/internal/dispatch/ContextClassLoaderDispatchTest.groovy
} public void cleanup() { Thread.currentThread().contextClassLoader = original } def 'sets ContextClassLoader during dispatch'() { when: dispatch.dispatch('message') then: 1 * target.dispatch('message') >> { assertContextClassloaderIs(appClassLoader) } 0 * _._ assertContextClassloaderIs(original) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/LogToClient.java
return; } dispatcher = new AsynchronousLogDispatcher(execution.getConnection(), build.getParameters().getLogLevel()); LOGGER.info("{}{}). The daemon log file: {}", DaemonMessages.STARTED_RELAYING_LOGS, diagnostics.getPid(), diagnostics.getDaemonLog()); dispatcher.start(); try { execution.proceed(); } finally { dispatcher.waitForCompletion(); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 6.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/mutating_work_estimator.go
// both phases of the request // - even more importantly, when a given `wide` request is the one to // be dispatched, we are not dispatching any other request until // we accumulate enough seats to dispatch the nominated one, even // if currently unoccupied seats would allow for dispatching some // other requests in the meantime
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:26:52 UTC 2023 - 6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/client/DaemonCancelForwarder.java
public DaemonCancelForwarder(final Dispatch<? super Cancel> dispatch, BuildCancellationToken cancellationToken) { this.cancellationToken = cancellationToken; cancellationCallback = new Runnable() { @Override public void run() { LOGGER.info("Request daemon to cancel build..."); dispatch.dispatch(new Cancel()); } }; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/hub/queue/QueueInitializer.java
* See the License for the specific language governing permissions and * limitations under the License. */ 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; public class QueueInitializer { private EndOfStream endOfStream;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0)