Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 65 for subscriber (0.19 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. internal/event/target/testdata/contrib/nats_tls_client_cert.conf

        key_file:   "./testdata/contrib/certs/nats_server_key.pem"
        ca_file:   "./testdata/contrib/certs/root_ca_cert.pem"
        verify_and_map: true
    }
    authorization {
        ADMIN = {
            publish = ">"
            subscribe = ">"
        }
        users = [
            {user: "CN=localhost,OU=Client,O=MinIO,C=CA", permissions: $ADMIN}
        ]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jun 01 21:59:40 UTC 2021
    - 426 bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top