Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for subscribed (0.07 sec)

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

      }
    
      /**
       * Tests that bridge methods are not subscribed to events. In Java 8, annotations are included on
       * the bridge method in addition to the original method, which causes both the original and bridge
       * methods to be subscribed (since both are annotated @Subscribe) without specifically checking
       * for bridge methods.
       */
      public void testRegistrationWithBridgeMethod() {
    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. cni/pkg/nodeagent/net.go

    	// the following fails.
    	// This is so that if it is removed from the mesh, the inpod rules will unconditionally
    	// be removed.
    
    	log.Debug("notifying subscribed node proxies")
    	if err := s.sendPodToZtunnelAndWaitForAck(ctx, pod, openNetns); err != nil {
    		return NewErrPartialAdd(err)
    	}
    	return nil
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Oct 21 16:48:55 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

        for (Entry<Class<?>, Collection<Subscriber>> entry : listenerMethods.asMap().entrySet()) {
          Class<?> eventType = entry.getKey();
          Collection<Subscriber> eventMethodsInListener = entry.getValue();
    
          CopyOnWriteArraySet<Subscriber> eventSubscribers = subscribers.get(eventType);
    
          if (eventSubscribers == null) {
            CopyOnWriteArraySet<Subscriber> newSet = new CopyOnWriteArraySet<>();
            eventSubscribers =
    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. compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-parent.xml

      <url>http://www.apache.org/</url>
    
      <mailingLists>
        <mailingList>
          <name>parent</name>
          <post>******@****.***</post>
          <subscribe>subscribe@mailing.list.com</subscribe>
          <unsubscribe>******@****.***</unsubscribe>
        </mailingList>
      </mailingLists>
    
      <build>
        <plugins>
          <plugin>
            <groupId>inheritance.configuration</groupId>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-child.xml

      <mailingLists>
        <!--mailingList> MNG-3124: no way to add a list to parent content, only full override
          <name>child</name>
          <post>******@****.***</post>
          <subscribe>subscribe@mailing.list.com</subscribe>
          <unsubscribe>******@****.***</unsubscribe>
        </mailingList-->
      </mailingLists>
    
      <build>
        <plugins>
          <plugin>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2K bytes
    - Viewed (0)
  6. compat/maven-model-builder/src/test/resources/poms/inheritance/plugin-configuration-expected.xml

      <url>http://www.apache.org/child/</url><!-- child's artifactId appended to parent url -->
    
      <mailingLists>
        <mailingList>
          <name>parent</name>
          <subscribe>subscribe@mailing.list.com</subscribe>
          <unsubscribe>******@****.***</unsubscribe>
          <post>******@****.***</post>
        </mailingList>
      </mailingLists>
    
      <build>
        <plugins>
          <plugin>
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  7. cmd/peer-rest-server.go

    	// Listen Publisher uses nonblocking publish and hence does not wait for slow subscribers.
    	// Use buffered channel to take care of burst sends or slow w.Write()
    	ch := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity())
    	err := globalHTTPListen.Subscribe(mask, ch, ctx.Done(), func(ev event.Event) bool {
    		if ev.S3.Bucket.Name != "" && values.Get(peerRESTListenBucket) != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  8. cmd/http-tracer.go

    		reqStartTime := time.Now().UTC()
    		h.ServeHTTP(respRecorder, r)
    		reqEndTime := time.Now().UTC()
    
    		if globalTrace.NumSubscribers(madmin.TraceS3|madmin.TraceInternal) == 0 {
    			// no subscribers nothing to trace.
    			return
    		}
    
    		tt := madmin.TraceInternal
    		if strings.HasPrefix(tc.FuncName, "s3.") {
    			tt = madmin.TraceS3
    		}
    
    		// Calculate input body size with headers
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 6K bytes
    - Viewed (0)
  9. docs/en/overrides/main.html

        </div>
        <div class="item">
          <a class="announce-link" href="https://fastapi.tiangolo.com/newsletter/">
            <span class="twemoji">
              {% include ".icons/material/email.svg" %}
            </span> Subscribe to the <strong>FastAPI and friends</strong> newsletter 🎉
          </a>
        </div>
        <div class="item">
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Thu Oct 31 09:13:26 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  10. README.md

    - **Community Slack**: [Join our Slack Channel](https://gradle.org/slack-invite) for real-time discussions, with specialized channels like `#github-integrations` for integration topics.
    - **Newsletter**: Subscribe to the [Gradle Newsletter](https://newsletter.gradle.org) for news, tutorials, and community highlights.
    
    > **Quick Tip**: New contributors to Gradle projects are encouraged to ask questions in the Slack `#community-support` channel.
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Nov 01 05:30:25 UTC 2024
    - 8K bytes
    - Viewed (0)
Back to top