- Sort Score
- Result 10 results
- Languages All
Results 151 - 160 of 1,050 for Revert (0.06 sec)
-
internal/event/targetlist.go
return ntargets } // Send - sends events to targets identified by target IDs. func (list *TargetList) Send(event Event, targetIDset TargetIDSet, sync bool) { if sync { list.sendSync(event, targetIDset) } else { list.sendAsync(event, targetIDset) } } func (list *TargetList) sendSync(event Event, targetIDset TargetIDSet) { var wg sync.WaitGroup for id := range targetIDset { target, ok := list.get(id)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/classrealm/ClassRealmManager.java
* * @return The class realm hosting the Maven core, never {@code null}. */ ClassRealm getCoreRealm(); /** * Gets the class realm exposing the Maven API. This is basically a restricted view on the Maven core realm. * * @return The class realm exposing the Maven API, never {@code null}. */ ClassRealm getMavenApiRealm(); /**
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4K bytes - Viewed (0) -
impl/maven-core/src/main/java/org/apache/maven/configuration/BeanConfigurationRequest.java
/** * Sets the bean to configure. Eventually, a valid request must have a bean set. * * @param bean The bean to configure, may be {@code null}. * @return This request for chaining, never {@code null}. */ BeanConfigurationRequest setBean(Object bean); /** * Gets the configuration to unmarshal into the bean. *
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.9K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/building/ModelBuildingEventCatapult.java
interface ModelBuildingEventCatapult { /** * Notifies the specified listener of the given event. * * @param listener The listener to notify, must not be {@code null}. * @param event The event to fire, must not be {@code null}. */ void fire(ModelBuildingListener listener, ModelBuildingEvent event); ModelBuildingEventCatapult BUILD_EXTENSIONS_ASSEMBLED = ModelBuildingListener::buildExtensionsAssembled;
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.5K bytes - Viewed (0) -
internal/config/lambda/event/targetlist.go
ntargets[k] = v } return ntargets } // Send - sends events to targets identified by target IDs. func (list *TargetList) Send(event Event, id TargetID) (*http.Response, error) { list.RLock() target, ok := list.targets[id] list.RUnlock() if ok { return target.Send(event) } return nil, ErrARNNotFound{} } // Stats returns stats for targets. func (list *TargetList) Stats() TargetStats {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Mar 07 16:12:41 UTC 2023 - 4.3K bytes - Viewed (0) -
.github/workflows/deploy-docs.yml
run-id: ${{ github.event.workflow_run.id }} - name: Deploy to Cloudflare Pages # hashFiles returns an empty string if there are no files if: hashFiles('./site/*') id: deploy env: PROJECT_NAME: fastapitiangolo
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sat Oct 26 09:37:59 UTC 2024 - 2.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java
holder.set(str); deliveries.incrementAndGet(); } }); String EVENT = "Hello!"; bus.post(EVENT); assertEquals("Only one event should be delivered.", 1, deliveries.get()); assertEquals("Correct string should be delivered.", EVENT, holder.get()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.8K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/ImmutableSetMultimap.java
*/ @Override public ImmutableSetMultimap<V, K> inverse() { ImmutableSetMultimap<V, K> result = inverse; return (result == null) ? (inverse = invert()) : result; } private ImmutableSetMultimap<V, K> invert() { Builder<V, K> builder = builder(); for (Entry<K, V> entry : entries()) { builder.put(entry.getValue(), entry.getKey()); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:05:46 UTC 2024 - 26.2K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
es.stats.missedFreeVersTasks.Add(1) } } // enqueueByDays enqueues object versions expired by days for expiry. func (es *expiryState) enqueueByDays(oi ObjectInfo, event lifecycle.Event, src lcEventSrc) { task := expiryTask{objInfo: oi, event: event, src: src} wrkr := es.getWorkerCh(task.OpHash()) if wrkr == nil { es.stats.missedExpiryTasks.Add(1) return } select { case <-GlobalContext.Done():
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
.github/workflows/build.yml
- name: Run Checks run: ./gradlew test -Dtest.java.version=11 testopenjdk8: runs-on: ubuntu-latest if: github.ref == 'refs/heads/master' || contains(github.event.pull_request.labels.*.name, 'jdkversions') || contains(github.event.pull_request.labels.*.name, 'renovate') steps: - name: Checkout uses: actions/checkout@v4 with: fetch-depth: 0
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Aug 17 10:05:29 UTC 2024 - 17.2K bytes - Viewed (0)