- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 412 for dispatchTo (0.18 sec)
-
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultBuildActionExecuterTest.groovy
start { thread.blockUntil.dispatched instant.resultAvailable wrappedHandler.onComplete(result) } } handler.onComplete(result) >> { instant.resultReceived } when: async { executer.run(handler) instant.dispatched thread.blockUntil.resultReceived }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 6.1K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/remote/internal/RemoteConnection.java
*/ public interface RemoteConnection<T> extends Connection<T> { /** * {@inheritDoc} * * @throws MessageIOException On failure to dispatch the message to the peer. */ @Override void dispatch(T message) throws MessageIOException; void flush() throws MessageIOException; /** * {@inheritDoc}
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.4K bytes - Viewed (0) -
okhttp-coroutines/README.md
call.executeAsync().use { response -> withContext(Dispatchers.IO) { println(response.body?.string()) } } ``` This is implemented using `suspendCancellableCoroutine` but uses the standard Dispatcher in OkHttp. This means that by default Kotlin's Dispatchers are not used. Cancellation if implemented sensibly in both directions. Cancelling a coroutine scope, will cancel the call.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Nov 09 15:47:27 UTC 2023 - 609 bytes - Viewed (0) -
analysis/analysis-api/src/org/jetbrains/kotlin/analysis/api/resolution/KaPartiallyAppliedSymbol.kt
/** * The function or variable (property) declaration. */ public val signature: C get() = withValidityAssertion { backingSignature } /** * The dispatch receiver for this symbol access. Dispatch receiver is available if the symbol is declared inside a class or object. */ public val dispatchReceiver: KaReceiverValue? by validityAsserted(dispatchReceiver) /**
Registered: Wed Jun 12 09:53:16 UTC 2024 - Last Modified: Wed Jun 05 16:16:39 UTC 2024 - 2.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/DefaultModelBuilderTest.groovy
start { thread.blockUntil.dispatched instant.resultAvailable wrappedHandler.onComplete(result) } } handler.onComplete(result) >> { instant.resultReceived } when: async { builder.get(handler) instant.dispatched thread.blockUntil.resultReceived }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 7.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/classpath/CompositeCallInterceptionTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 11:38:52 UTC 2024 - 8.2K bytes - Viewed (0) -
platforms/core-runtime/messaging/src/main/java/org/gradle/internal/dispatch/ExceptionTrackingFailureHandler.java
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.internal.dispatch; import org.gradle.internal.concurrent.Stoppable; import org.slf4j.Logger; public class ExceptionTrackingFailureHandler implements DispatchFailureHandler<Object>, Stoppable { private final Logger logger;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:59:22 UTC 2023 - 1.6K bytes - Viewed (0) -
maven-settings-builder/src/main/java/org/apache/maven/settings/crypto/DefaultSettingsDecrypter.java
import org.apache.maven.settings.building.SettingsProblem; import org.apache.maven.settings.building.SettingsProblem.Severity; import org.sonatype.plexus.components.sec.dispatcher.SecDispatcher; import org.sonatype.plexus.components.sec.dispatcher.SecDispatcherException; /** * Decrypts passwords in the settings. * */ @Named @Singleton public class DefaultSettingsDecrypter implements SettingsDecrypter {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Sep 06 08:39:32 UTC 2023 - 3.9K bytes - Viewed (0) -
src/site/xdoc/maven-deps.odg
Maven 4 API sisu plexus inject guice plexus core distribution sec-dispatcher commons-cli utils plugin-api artifact embedder settings-builder model-builder model cipher interpolation wagon-provider-api classworlds repository-metadata settings resolver api spi impl util resolver-provider builder-support jansi slf4j-api shared-utils slf4j-provider bom toolchain-builder toolchain-model meta di xml model plugin toolchain core spi xml-impl xml settings jline3 compat slf4j-wrapper jline woodstox api-impl...
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Apr 24 16:01:00 UTC 2024 - 37K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/tooling/internal/provider/StreamedValueConsumer.java
} @Override public void dispatch(Object message) { if (message instanceof StreamedValue) { StreamedValue value = (StreamedValue) message; Object deserializedValue = payloadSerializer.deserialize(value.getSerializedModel()); providerParameters.onStreamedValue(deserializedValue); } else { delegate.dispatch(message); } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 19 08:15:25 UTC 2023 - 1.8K bytes - Viewed (0)