- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 149 for subscript (0.18 sec)
-
android/guava/src/com/google/common/eventbus/package-info.java
* the License. */ /** * <a href="https://guava.dev/EventBus">Discouraged</a> in favor of dependency injection and * concurrency frameworks, EventBus allows publish-subscribe-style communication. * * <p>See the Guava User Guide article on <a * href="https://github.com/google/guava/wiki/EventBusExplained">{@code EventBus}</a>. */ @CheckReturnValue @ParametersAreNonnullByDefault
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 23 19:57:03 UTC 2023 - 1.1K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/AllowConcurrentEvents.java
* may invoke the event subscriber simultaneously from multiple threads. * * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}. * * @author Cliff Biffle * @since 10.0 */ @Retention(RetentionPolicy.RUNTIME) @Target(ElementType.METHOD) @ElementTypesAreNonnullByDefault
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Apr 22 13:05:46 UTC 2021 - 1.2K bytes - Viewed (0) -
subprojects/build-events/src/main/java/org/gradle/internal/build/event/BuildEventListenerRegistryInternal.java
*/ void onOperationCompletion(Provider<? extends BuildOperationListener> provider); void subscribe(Provider<?> provider); List<Provider<?>> getSubscriptions();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 1.4K bytes - Viewed (0) -
maven-core/src/test/resources/org/apache/maven/extension/test-extension-repo/org/codehaus/plexus/plexus/1.0.8/plexus-1.0.8.pom
</notifier> </notifiers> </ciManagement> <inceptionYear>2001</inceptionYear> <mailingLists> <mailingList> <name>Plexus Developer List</name> <subscribe>http://lists.codehaus.org/mailman/listinfo/plexus-dev</subscribe> <unsubscribe>http://lists.codehaus.org/mailman/listinfo/plexus-dev</unsubscribe> <archive>http://lists.codehaus.org/pipermail/plexus-dev/</archive> </mailingList>
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Dec 24 18:09:10 UTC 2020 - 7.1K bytes - Viewed (0) -
internal/pubsub/pubsub.go
if sub.types.Contains(Mask(item.Mask())) && (sub.filter == nil || sub.filter(item)) { select { case sub.ch <- item: default: } } } } // Subscribe - Adds a subscriber to pubsub system func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error { totalSubs := atomic.AddInt32(&ps.numSubscribers, 1) if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Feb 06 16:57:30 UTC 2024 - 5.2K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE.md
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sat Jan 29 00:04:16 UTC 2022 - 2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/configuration/ProjectScriptTarget.java
} @Override public Class<? extends BasicScript> getScriptClass() { return ProjectScript.class; } @Override public void attachScript(Script script) { target.setScript(script); } @Override public void addConfiguration(Runnable runnable, boolean deferrable) { if (deferrable) { target.addDeferredConfiguration(runnable); } else {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Jun 09 11:18:20 UTC 2021 - 2.5K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/bug_report.md
--- name: Bug report about: Create a report to help us improve title: '' labels: community, triage assignees: '' --- ## NOTE If this case is urgent, please subscribe to [Subnet](https://min.io/pricing) so that our 24/7 support team may help you faster. <!--- Provide a general summary of the issue in the Title above --> ## Expected Behavior <!--- If you're describing a bug, tell us what should happen -->
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jan 20 17:37:40 UTC 2022 - 1.7K bytes - Viewed (0) -
platforms/jvm/language-java/src/integTest/groovy/org/gradle/api/tasks/compile/JavaCompileTaskOperationResultIntegTest.groovy
fixture.writeSupportLibraryTo(processorProjectDir) } @Issue("https://github.com/gradle/gradle/issues/22999") def "listener added during doFirst of JavaCompile can subscribe to task completion events but does not get a callback"() { buildFile << """ import javax.inject.Inject import org.gradle.api.services.BuildService
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Aug 28 11:40:18 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/kubelet/container/cache_test.go
podID, status := getTestPodIDAndStatus(1) ch := cache.subscribe(podID, cacheTime.Add(time.Second)) verifyNotification(t, ch, false) cache.Set(podID, status, nil, cacheTime.Add(time.Second)) // The Set operation should've triggered the notification. verifyNotification(t, ch, true) podID, _ = getTestPodIDAndStatus(1) ch = cache.subscribe(podID, cacheTime.Add(time.Second)) verifyNotification(t, ch, false)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 24 20:23:12 UTC 2020 - 6K bytes - Viewed (0)