Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for subscribers (0.1 sec)

  1. internal/pubsub/pubsub.go

    	}
    	return atomic.LoadInt32(&ps.numSubscribers)
    }
    
    // Subscribers returns the number of current subscribers for all types.
    func (ps *PubSub[T, M]) Subscribers() int32 {
    	return atomic.LoadInt32(&ps.numSubscribers)
    }
    
    // New inits a PubSub system with a limit of maximum
    // subscribers unless zero is specified
    func New[T Maskable, M Maskable](maxSubscribers int32) *PubSub[T, M] {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Feb 06 16:57:30 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  2. guava/src/com/google/common/eventbus/Dispatcher.java

          private final Iterator<Subscriber> subscribers;
    
          private Event(Object event, Iterator<Subscriber> subscribers) {
            this.event = event;
            this.subscribers = subscribers;
          }
        }
      }
    
      /** Implementation of a {@link #legacyAsync()} dispatcher. */
      private static final class LegacyAsyncDispatcher extends Dispatcher {
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Dec 15 19:31:54 UTC 2023
    - 7.3K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

        }
      }
    
      @VisibleForTesting
      Set<Subscriber> getSubscribersForTesting(Class<?> eventType) {
        return MoreObjects.firstNonNull(subscribers.get(eventType), ImmutableSet.<Subscriber>of());
      }
    
      /**
       * Gets an iterator representing an immutable snapshot of all subscribers to the given event at
       * the time this method is called.
       */
      Iterator<Subscriber> getSubscribers(Object event) {
    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. android/guava-tests/test/com/google/common/eventbus/DispatcherTest.java

                i1,
                i2,
                i3, // Integer subscribers are dispatched to first.
                s1,
                s2, // Though each integer subscriber dispatches to all string subscribers,
                s1,
                s2, // those string subscribers aren't actually dispatched to until all integer
                s1,
                s2 // subscribers have finished.
                )
            .inOrder();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 27 15:41:25 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  5. internal/pubsub/pubsub_test.go

    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(Mask(2)); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(Mask(1|2)); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    	if want, got := int32(2), ps.NumSubscribers(MaskAll); got != want {
    		t.Fatalf("want %d subscribers, got %d", want, got)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/eventbus/DispatcherTest.java

                i1,
                i2,
                i3, // Integer subscribers are dispatched to first.
                s1,
                s2, // Though each integer subscriber dispatches to all string subscribers,
                s1,
                s2, // those string subscribers aren't actually dispatched to until all integer
                s1,
                s2 // subscribers have finished.
                )
            .inOrder();
      }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Apr 27 15:41:25 UTC 2022
    - 5.6K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java

      private @Nullable H subscriber;
    
      H getSubscriber() {
        return subscriber;
      }
    
      @Override
      protected void setUp() throws Exception {
        subscriber = createSubscriber();
        EventBus bus = new EventBus();
        bus.register(subscriber);
        bus.post(EVENT);
      }
    
      @Override
      protected void tearDown() throws Exception {
        subscriber = null;
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 17 15:19:38 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  8. 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)
  9. guava-tests/test/com/google/common/eventbus/outside/AbstractEventBusTest.java

      private @Nullable H subscriber;
    
      H getSubscriber() {
        return subscriber;
      }
    
      @Override
      protected void setUp() throws Exception {
        subscriber = createSubscriber();
        EventBus bus = new EventBus();
        bus.register(subscriber);
        bus.post(EVENT);
      }
    
      @Override
      protected void tearDown() throws Exception {
        subscriber = null;
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Apr 17 15:19:38 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  10. cmd/consolelogger.go

    // for this node or peers
    func (sys *HTTPConsoleLoggerSys) HasLogListeners() bool {
    	return sys != nil && sys.pubsub.Subscribers() > 0
    }
    
    // Subscribe starts console logging for this node.
    func (sys *HTTPConsoleLoggerSys) Subscribe(subCh chan log.Info, doneCh <-chan struct{}, node string, last int, logKind madmin.LogMask, filter func(entry log.Info) bool) error {
    	// Enable console logging for remote client.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top