Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 177 for eventbus (0.05 sec)

  1. android/guava-tests/test/com/google/common/eventbus/EventBusTest.java

              catcher.getEvents());
        }
      }
    
      public void testToString() throws Exception {
        EventBus eventBus = new EventBus("a b ; - \" < > / \\ €");
        assertEquals("EventBus{a b ; - \" < > / \\ €}", eventBus.toString());
      }
    
      /**
       * Tests that bridge methods are not subscribed to events. In Java 8, annotations are included on
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 15:16:45 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/eventbus/PackageSanityTests.java

        private final EventBus eventBus = new EventBus();
    
        @Subscribe
        public void handle(@Nullable Object unused) {}
    
        Subscriber toSubscriber() throws Exception {
          return Subscriber.create(eventBus, this, subscriberMethod());
        }
    
        SubscriberExceptionContext toContext() {
          return new SubscriberExceptionContext(eventBus, new Object(), this, subscriberMethod());
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 02 18:21:29 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

       */
      private final ConcurrentMap<Class<?>, CopyOnWriteArraySet<Subscriber>> subscribers =
          Maps.newConcurrentMap();
    
      /** The event bus this registry belongs to. */
      @Weak private final EventBus bus;
    
      SubscriberRegistry(EventBus bus) {
        this.bus = checkNotNull(bus);
      }
    
      /** Registers all subscriber methods on the given listener object. */
      void register(Object listener) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 15:16:45 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/eventbus/Dispatcher.java

     * the License.
     */
    
    package com.google.common.eventbus;
    
    import static com.google.common.base.Preconditions.checkNotNull;
    import static java.util.Objects.requireNonNull;
    
    import com.google.common.collect.Queues;
    import java.util.Iterator;
    import java.util.Queue;
    import java.util.concurrent.ConcurrentLinkedQueue;
    
    /**
     * Handler for dispatching events to subscribers, providing different event ordering guarantees that
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  5. .github/ISSUE_TEMPLATE/bug_report.yaml

          options:
            - com.google.common.annotations
            - com.google.common.base
            - com.google.common.cache
            - com.google.common.collect
            - com.google.common.escape
            - com.google.common.eventbus
            - com.google.common.graph
            - com.google.common.hash
            - com.google.common.io
            - com.google.common.math
            - com.google.common.net
            - com.google.common.primitives
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Jul 16 20:08:25 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/collect/WriteReplaceOverridesTest.java

      private static final ImmutableSet<String> GUAVA_PACKAGES =
          FluentIterable.of(
                  "base",
                  "cache",
                  "collect",
                  "escape",
                  "eventbus",
                  "graph",
                  "hash",
                  "html",
                  "io",
                  "math",
                  "net",
                  "primitives",
                  "reflect",
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 18:53:31 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/collect/WriteReplaceOverridesTest.java

      private static final ImmutableSet<String> GUAVA_PACKAGES =
          FluentIterable.of(
                  "base",
                  "cache",
                  "collect",
                  "escape",
                  "eventbus",
                  "graph",
                  "hash",
                  "html",
                  "io",
                  "math",
                  "net",
                  "primitives",
                  "reflect",
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jul 24 18:53:31 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  8. .github/ISSUE_TEMPLATE/feature_addition_request.yaml

            - com.google.common.annotations
            - com.google.common.base
            - com.google.common.cache
            - com.google.common.collect
            - com.google.common.escape
            - com.google.common.eventbus
            - com.google.common.graph
            - com.google.common.hash
            - com.google.common.io
            - com.google.common.math
            - com.google.common.net
            - com.google.common.primitives
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Nov 17 18:47:47 UTC 2023
    - 5.8K bytes
    - Viewed (0)
  9. docs/pt/docs/advanced/events.md

    ```Python hl_lines="22"
    {!../../docs_src/events/tutorial003.py!}
    ```
    
    ## Eventos alternativos (deprecados)
    
    /// warning | "Aviso"
    
    A maneira recomendada para lidar com a *inicialização* e o *encerramento* é usando o parâmetro `lifespan` da aplicação `FastAPI` como descrito acima.
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  10. docs/zh/docs/advanced/events.md

    使用 `startup` 事件声明 `app` 启动前运行的函数:
    
    ```Python hl_lines="8"
    {!../../docs_src/events/tutorial001.py!}
    ```
    
    本例中,`startup` 事件处理器函数为项目数据库(只是**字典**)提供了一些初始值。
    
    **FastAPI** 支持多个事件处理器函数。
    
    只有所有 `startup` 事件处理器运行完毕,**FastAPI** 应用才开始接收请求。
    
    ## `shutdown` 事件
    
    使用 `shutdown` 事件声明 `app` 关闭时运行的函数:
    
    ```Python hl_lines="6"
    {!../../docs_src/events/tutorial002.py!}
    ```
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 1.7K bytes
    - Viewed (0)
Back to top