- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 65 for subscriber (0.19 sec)
-
guava-tests/test/com/google/common/eventbus/outside/OutsideEventBusTest.java
* limitations under the License. */ package com.google.common.eventbus.outside; import com.google.common.eventbus.EventBus; import com.google.common.eventbus.Subscribe; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicReference; import junit.framework.TestCase; /** * Test cases for {@code EventBus} that must not be in the same package. *
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.8K bytes - Viewed (0) -
tests/test_webhooks_security.py
start_date: datetime @app.webhooks.post("new-subscription") def new_subscription( body: Subscription, token: Annotated[str, Security(bearer_scheme)] ): """ When a new user subscribes to your service we'll send you a POST request with this data to the URL that you register for the event `new-subscription` in the dashboard. """ client = TestClient(app) def test_dummy_webhook():
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Oct 20 09:00:44 UTC 2023 - 4.6K bytes - Viewed (0) -
docs_src/openapi_webhooks/tutorial001.py
class Subscription(BaseModel): username: str monthly_fee: float start_date: datetime @app.webhooks.post("new-subscription") def new_subscription(body: Subscription): """ When a new user subscribes to your service we'll send you a POST request with this data to the URL that you register for the event `new-subscription` in the dashboard. """ @app.get("/users/") def read_users():
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Oct 20 09:00:44 UTC 2023 - 550 bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/package-info.java
* the License. */ /** * <a href="https://guava.dev/EventBus">Discouraged</a> 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 @ParametersAreNonnullByDefault
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 23 19:57:03 UTC 2023 - 1.1K bytes - Viewed (0) -
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) -
internal/event/target/testdata/contrib/nats_tls_client_cert.conf
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jun 01 21:59:40 UTC 2021 - 426 bytes - Viewed (0) -
cmd/background-heal-ops.go
} func activeListeners() int { // Bucket notification and http trace are not costly, it is okay to ignore them // while counting the number of concurrent connections return int(globalHTTPListen.Subscribers()) + int(globalTrace.Subscribers()) } func waitForLowIO(maxIO int, maxWait time.Duration, currentIO func() int) { // No need to wait run at full speed. if maxIO <= 0 { return }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
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. }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 1.2K bytes - Viewed (0) -
guava/src/com/google/common/eventbus/package-info.java
* the License. */ /** * <a href="https://guava.dev/EventBus">Discouraged</a> 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 @ParametersAreNonnullByDefault
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Jun 23 19:57:03 UTC 2023 - 1.1K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/AsyncEventBus.java
* down the executor after the last event has been posted to this event bus. * @param subscriberExceptionHandler Handler used to handle exceptions thrown from subscribers. * See {@link SubscriberExceptionHandler} for more information. * @since 16.0 */ public AsyncEventBus(Executor executor, SubscriberExceptionHandler subscriberExceptionHandler) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Apr 22 13:05:46 UTC 2021 - 2.5K bytes - Viewed (0)