- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for dispatchEvents (0.29 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
// the reflector to issue a regular LIST against the store reflector.UseWatchList = ptr.To(false) cacher.watchCache = watchCache cacher.reflector = reflector go cacher.dispatchEvents() go progressRequester.Run(stopCh) cacher.stopWg.Add(1) go func() { defer cacher.stopWg.Done() defer cacher.terminateAllWatchers() wait.Until( func() { if !cacher.isStopped() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/DaemonConnectionBackedEventConsumer.java
} @Override public void run() { while (moreMessagesToSend()) { Object event = getNextEvent(); if (event != null) { dispatchEvent(event); } } } private boolean moreMessagesToSend() { return ableToSend && !(stopped && queue.isEmpty()); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.9K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Dispatcher.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 7.3K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Subscriber.java
this.method = method; method.setAccessible(true); this.executor = bus.executor(); } /** Dispatches {@code event} to this subscriber using the proper executor. */ final void dispatchEvent(Object event) { executor.execute( () -> { try { invokeSubscriberMethod(event); } catch (InvocationTargetException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/Subscriber.java
this.method = method; method.setAccessible(true); this.executor = bus.executor(); } /** Dispatches {@code event} to this subscriber using the proper executor. */ final void dispatchEvent(Object event) { executor.execute( () -> { try { invokeSubscriberMethod(event); } catch (InvocationTargetException e) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Oct 06 00:47:57 UTC 2021 - 4.7K bytes - Viewed (0) -
src/internal/trace/traceviewer/static/webcomponents.min.js
ction(e){if(e["import"]=e.__doc,window.HTMLImports.__importsParsingHook&&window.HTMLImports.__importsParsingHook(e),e["import"]&&(e["import"].__importParsed=!0),this.markParsingComplete(e),e.__resource&&!e.__error?e.dispatchEvent(new CustomEvent("load",{bubbles:!1})):e.dispatchEvent(new CustomEvent("error",{bubbles:!1})),e.__pending)for(var t;e.__pending.length;)t=e.__pending.shift(),t&&t({target:e});this.parseNext()},parseLink:function(e){t(e)?this.parseImport(e):(e.href=e.href,this.parseGeneri...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 115.6K bytes - Viewed (0) -
src/internal/trace/traceviewer/static/trace_viewer_full.html
RegisteredTypeInfo(constructor,metadata);let e=new tr.b.Event('will-register');e.typeInfo=typeInfo;registry.dispatchEvent(e);registry.registeredTypeInfos_.push(typeInfo);e=new tr.b.Event('registry-changed');registry.dispatchEvent(e);};registry.pushCleanStateBeforeTest=function(){savedStateStack.push(registry.registeredTypeInfos_);registry.registeredTypeInfos_=[];const e=new tr.b.Event('registry-changed');registry.dispatchEvent(e);};registry.popCleanStateAfterTest=function(){registry.registeredTypeInfos_=savedState...
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 20:45:06 UTC 2023 - 2.5M bytes - Viewed (0) -
okhttp-android/src/main/baseline-prof.txt
HSPLandroidx/lifecycle/LifecycleRegistry$ObserverWithState;-><init>(Landroidx/lifecycle/LifecycleObserver;Landroidx/lifecycle/Lifecycle$State;)V HSPLandroidx/lifecycle/LifecycleRegistry$ObserverWithState;->dispatchEvent(Landroidx/lifecycle/LifecycleOwner;Landroidx/lifecycle/Lifecycle$Event;)V HSPLandroidx/lifecycle/LifecycleRegistry;-><init>(Landroidx/lifecycle/LifecycleOwner;)V
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Mar 21 11:22:00 UTC 2022 - 127.9K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/resources/org/gradle/api/internal/artifacts/ivyservice/ivyresolve/verification/report/uikit.min.js
Gt(){for(var t=[],e=arguments.length;e--;)t[e]=arguments[e];var i=Zt(t),n=i[0],r=i[1],o=i[2],s=i[3],a=i[4],h=i[5],u=Ut(n,r,o,function(t){var e=!h||h(t);e&&(u(),s(t,e))},a);return u}function Kt(t,i,n){return ie(t).reduce(function(t,e){return t&&e.dispatchEvent(Jt(i,!0,!0,n))},!0)}function Jt(t,e,i,n){if(void 0===e&&(e=!0),void 0===i&&(i=!1),D(t)){var r=document.createEvent("CustomEvent");r.initCustomEvent(t,e,i,n),t=r}return t}function Zt(t){return $(t[2])&&t.splice(2,0,!1),t}function Qt(t){return t...
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 130.5K bytes - Viewed (0)