Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 59 for eventbus (0.12 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. 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. okhttp/src/main/kotlin/okhttp3/EventListener.kt

     * request body start and end events occur within the response header events. Similarly,
     * [duplex calls][RequestBody.isDuplex] interleave the request and response bodies.
     *
     * Since connections may be reused, the proxy selection, DNS, and connect events may not be present
     * for a call. In future releases of OkHttp these events may also occur concurrently to permit
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/lifecycle.go

    						// This is a MinIO only extension.
    						event.Action = DeleteAllVersionsAction
    					}
    					events = append(events, event)
    				}
    			}
    
    			if obj.TransitionStatus != TransitionComplete {
    				if due, ok := rule.Transition.NextDue(obj); ok && (now.IsZero() || now.After(due)) {
    					events = append(events, Event{
    						Action:       TransitionAction,
    						RuleID:       rule.ID,
    						Due:          due,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

        cancelLatch.await()
    
        val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name }
        listener.clearAllEvents()
    
        assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired")
        if (cancelMode == CANCEL) {
          assertThat(events).contains("Canceled")
        } else {
          assertThat(events).doesNotContain("Canceled")
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  6. internal/event/target/kafka.go

    			// Such events will not exist and wouldve been already been sent successfully.
    			if os.IsNotExist(err) {
    				return nil
    			}
    			return err
    		}
    		err = target.send(event)
    	case key.ItemCount > 1:
    		var events []event.Event
    		events, err = target.store.GetMultiple(key)
    		if err != nil {
    			if os.IsNotExist(err) {
    				return nil
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  7. compat/maven-compat/src/test/java/org/apache/maven/repository/legacy/DefaultWagonManagerTest.java

    import org.apache.maven.wagon.TransferFailedException;
    import org.apache.maven.wagon.UnsupportedProtocolException;
    import org.apache.maven.wagon.Wagon;
    import org.apache.maven.wagon.events.TransferEvent;
    import org.apache.maven.wagon.events.TransferListener;
    import org.apache.maven.wagon.observers.AbstractTransferListener;
    import org.apache.maven.wagon.observers.Debug;
    import org.codehaus.plexus.testing.PlexusTest;
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  8. internal/config/notify/help.go

    	queueLimitComment = `maximum limit for undelivered messages, defaults to '100000'`
    )
    
    // Help template inputs for all notification targets
    var (
    	HelpWebhook = config.HelpKVS{
    		config.HelpKV{
    			Key:         target.WebhookEndpoint,
    			Description: "webhook server endpoint e.g. http://localhost:8080/minio/events",
    			Type:        "url",
    			Sensitive:   true,
    		},
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 19.2K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        return NANOSECONDS.toMillis(stopwatch.instant - startTime);
      }
    
      private void assertEvents(String... events) {
        assertEquals(Arrays.toString(events), stopwatch.readEventsAndClear());
      }
    
      /**
       * The stopwatch gathers events and presents them as strings. R0.6 means a delay of 0.6 seconds
       * caused by the (R)ateLimiter U1.0 means the (U)ser caused the stopwatch to sleep for a second.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
Back to top