Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 7 of 7 for dispatchEvent (0.35 seconds)

  1. android/guava/src/com/google/common/eventbus/Dispatcher.java

            try {
              Event nextEvent;
              while ((nextEvent = queueForThread.poll()) != null) {
                while (nextEvent.subscribers.hasNext()) {
                  nextEvent.subscribers.next().dispatchEvent(nextEvent.event);
                }
              }
            } finally {
              dispatching.remove();
              queue.remove();
            }
          }
        }
    
        private static final class Event {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  2. 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) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/helper/CoordinatorHelper.java

            }
    
            try {
                final List<EventInfo> events = fetchNewEvents();
                for (final EventInfo event : events) {
                    dispatchEvent(event);
                }
            } catch (final Exception e) {
                logger.debug("Failed to process events in poll.", e);
            }
    
            try {
                cleanupExpiredDocuments();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 33.3K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/helper/CoordinatorHelperTest.java

            configEvent.name = "config_updated";
            coordinatorHelper.dispatchEvent(configEvent);
            assertEquals("config", received.get());
    
            final EventInfo dictEvent = new EventInfo();
            dictEvent.name = "dict_updated";
            coordinatorHelper.dispatchEvent(dictEvent);
            assertEquals("dict", received.get());
        }
    
        @Test
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 58.6K bytes
    - Click Count (0)
  5. src/main/webapp/js/bootstrap.min.js

    (t)&&i.get(t).get(e)||null,remove(t,e){if(!i.has(t))return;const s=i.get(t);s.delete(e),0===s.size&&i.delete(t)}},o="transitionend",r=t=>(t&&window.CSS&&window.CSS.escape&&(t=t.replace(/#([^\s"#']+)/g,((t,e)=>`#${CSS.escape(e)}`))),t),a=t=>{t.dispatchEvent(new Event(o))},l=t=>!(!t||"object"!=typeof t)&&(void 0!==t.jquery&&(t=t[0]),void 0!==t.nodeType),c=t=>l(t)?t.jquery?t[0]:t:"string"==typeof t&&t.length>0?document.querySelector(r(t)):null,h=t=>{if(!l(t)||0===t.getClientRects().length)return!1;const...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 12 06:14:02 GMT 2025
    - 58.9K bytes
    - Click Count (0)
  6. okhttp/src/androidMain/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
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Dec 30 23:28:56 GMT 2024
    - 127.9K bytes
    - Click Count (1)
  7. src/main/webapp/js/bootstrap.min.js.map

    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 12 06:14:02 GMT 2025
    - 211.9K bytes
    - Click Count (0)
Back to Top