Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 49 for unsubscribe (0.05 seconds)

  1. guava/src/com/google/common/eventbus/package-info.java

     * the License.
     */
    
    /**
     * {@linkplain EventBus Discouraged} in favor of dependency injection and concurrency frameworks,
     * EventBus allows publish-subscribe-style communication.
     *
     * <p>See the Guava User Guide article on <a
     * href="https://github.com/google/guava/wiki/EventBusExplained">{@code EventBus}</a>.
     */
    @CheckReturnValue
    @NullMarked
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Fri Jan 03 19:02:39 GMT 2025
    - 1K bytes
    - Click Count (0)
  2. guava/src/com/google/common/eventbus/AllowConcurrentEvents.java

     * may invoke the event subscriber simultaneously from multiple threads.
     *
     * <p>This does not mark the method, and so should be used in combination with {@link Subscribe}.
     *
     * @author Cliff Biffle
     * @since 10.0
     */
    @Retention(RetentionPolicy.RUNTIME)
    @Target(ElementType.METHOD)
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sat Dec 21 03:10:51 GMT 2024
    - 1.2K bytes
    - Click Count (0)
  3. guava-tests/benchmark/com/google/common/eventbus/EventBusBenchmark.java

        eventBus.register(this);
      }
    
      @Benchmark
      void postStrings(int reps) {
        for (int i = 0; i < reps; i++) {
          eventBus.post("hello there");
        }
      }
    
      @Subscribe
      public void handleStrings(String string) {
        // Nothing to do here.
      }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 19 18:03:30 GMT 2024
    - 1.2K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/eventbus/PackageSanityTests.java

        setDefault(Dispatcher.class, Dispatcher.immediate());
      }
    
      private static class DummySubscriber {
    
        private final EventBus eventBus = new EventBus();
    
        @Subscribe
        public void handle(@Nullable Object unused) {}
    
        Subscriber toSubscriber() throws Exception {
          return Subscriber.create(eventBus, this, subscriberMethod());
        }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 2K bytes
    - Click Count (0)
  5. docs/en/docs/js/custom.js

                // do nothing
            });
    }
    
    async function main() {
        setupTermynal();
        showRandomAnnouncement('announce-left', 5000)
        handleSponsorImages();
    }
    document$.subscribe(() => {
        main()
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Sep 22 15:11:52 GMT 2025
    - 6.3K bytes
    - Click Count (2)
  6. 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>
      <div id="announce-right" style="position: relative;">
        <div class="item">
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Dec 01 20:06:57 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  7. docs/en/docs/help-fastapi.md

    Or would you like to get help with **FastAPI**?
    
    There are very simple ways to help (several involve just one or two clicks).
    
    And there are several ways to get help too.
    
    ## Subscribe to the newsletter { #subscribe-to-the-newsletter }
    
    You can subscribe to the (infrequent) [**FastAPI and friends** newsletter](newsletter.md){.internal-link target=_blank} to stay updated about:
    
    * News about FastAPI and friends 🚀
    * Guides 📝
    * Features ✨
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sun Aug 31 10:49:48 GMT 2025
    - 14K bytes
    - Click Count (0)
  8. docs/bucket/notifications/README.md

          if c.NatsConn() != nil {
           c.NatsConn().Close()
          }
          _ = c.Close()
         }))
         if stanConnection != nil {
          subscribe()
         }
    
        }
       }
    
      }()
     }))
    
     // Subscribe to subject
     subscribe()
    
     // Keep the connection alive
     runtime.Goexit()
    }
    
    ```
    
    ```
    go run nats.go
    2017/07/07 11:47:40 Connected
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 84.2K bytes
    - Click Count (0)
  9. cmd/listen-notification-handlers.go

    			case <-ctx.Done():
    				grid.PutByteBuffer(buf.Bytes())
    				return
    			}
    		}
    	}()
    	peers, _ := newPeerRestClients(globalEndpoints)
    	err := globalHTTPListen.Subscribe(mask, localCh, ctx.Done(), func(ev event.Event) bool {
    		if ev.S3.Bucket.Name != "" && bucketName != "" {
    			if ev.S3.Bucket.Name != bucketName {
    				return false
    			}
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 6K bytes
    - Click Count (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.
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Mon Oct 20 22:15:26 GMT 2025
    - 7.8K bytes
    - Click Count (0)
Back to Top