Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 265 for eventbus (0.13 sec)

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

     * the License.
     */
    
    package com.google.common.eventbus;
    
    import java.lang.annotation.ElementType;
    import java.lang.annotation.Retention;
    import java.lang.annotation.RetentionPolicy;
    import java.lang.annotation.Target;
    
    /**
     * Marks an event subscriber method as being thread-safe. This annotation indicates that EventBus
     * may invoke the event subscriber simultaneously from multiple threads.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 1.2K bytes
    - Viewed (0)
  2. 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)
  3. android/guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.eventbus;
    
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableSet;
    import com.google.common.collect.Iterators;
    import java.util.Iterator;
    import junit.framework.TestCase;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  4. guava-tests/test/com/google/common/eventbus/SubscriberRegistryTest.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.eventbus;
    
    import static org.junit.Assert.assertThrows;
    
    import com.google.common.collect.ImmutableSet;
    import com.google.common.collect.Iterators;
    import java.util.Iterator;
    import junit.framework.TestCase;
    
    /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Sep 06 17:04:31 UTC 2023
    - 5.7K bytes
    - Viewed (0)
  5. guava/src/com/google/common/eventbus/SubscriberExceptionHandler.java

     * or implied. See the License for the specific language governing permissions and limitations under
     * the License.
     */
    
    package com.google.common.eventbus;
    
    
    /**
     * Handler for exceptions thrown by event subscribers.
     *
     * @since 16.0
     */
    @ElementTypesAreNonnullByDefault
    public interface SubscriberExceptionHandler {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 928 bytes
    - Viewed (0)
  6. 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)
  7. android/guava/src/com/google/common/eventbus/SubscriberExceptionHandler.java

     * or implied. See the License for the specific language governing permissions and limitations under
     * the License.
     */
    
    package com.google.common.eventbus;
    
    
    /**
     * Handler for exceptions thrown by event subscribers.
     *
     * @since 16.0
     */
    @ElementTypesAreNonnullByDefault
    public interface SubscriberExceptionHandler {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 928 bytes
    - Viewed (0)
  8. .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)
  9. guava/src/com/google/common/eventbus/ElementTypesAreNonnullByDefault.java

     * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
     * See the License for the specific language governing permissions and
     * limitations under the License.
     */
    
    package com.google.common.eventbus;
    
    import static java.lang.annotation.ElementType.FIELD;
    import static java.lang.annotation.ElementType.METHOD;
    import static java.lang.annotation.ElementType.PARAMETER;
    import static java.lang.annotation.ElementType.TYPE;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Apr 22 13:05:46 UTC 2021
    - 1.5K bytes
    - Viewed (0)
  10. 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)
Back to top