Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 44 for subscribed (0.05 seconds)

  1. android/guava/src/com/google/common/eventbus/SubscriberExceptionContext.java

       * @param subscriber The source subscriber context.
       * @param subscriberMethod the subscribed method.
       */
      SubscriberExceptionContext(
          EventBus eventBus, Object event, Object subscriber, Method subscriberMethod) {
        this.eventBus = checkNotNull(eventBus);
        this.event = checkNotNull(event);
        this.subscriber = checkNotNull(subscriber);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Sep 11 17:06:34 GMT 2025
    - 2.2K bytes
    - Click Count (0)
  2. internal/pubsub/pubsub.go

    			default:
    			}
    		}
    	}
    }
    
    // Subscribe - Adds a subscriber to pubsub system
    func (ps *PubSub[T, M]) Subscribe(mask M, subCh chan T, doneCh <-chan struct{}, filter func(entry T) bool) error {
    	totalSubs := atomic.AddInt32(&ps.numSubscribers, 1)
    	if ps.maxSubscribers > 0 && totalSubs > ps.maxSubscribers {
    		atomic.AddInt32(&ps.numSubscribers, -1)
    		return fmt.Errorf("the limit of `%d` subscribers is reached", ps.maxSubscribers)
    	}
    	ps.Lock()
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 06 16:57:30 GMT 2024
    - 5.2K bytes
    - Click Count (0)
  3. 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.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 5.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/eventbus/Subscriber.java

      static Subscriber create(EventBus bus, Object listener, Method method) {
        return isDeclaredThreadSafe(method)
            ? new Subscriber(bus, listener, method)
            : new SynchronizedSubscriber(bus, listener, method);
      }
    
      /** The event bus this subscriber belongs to. */
      @Weak private final EventBus bus;
    
      /** The object with the subscriber method. */
      @VisibleForTesting final Object target;
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed May 14 19:40:47 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  5. android/guava/src/com/google/common/eventbus/Subscribe.java

     * the {@link EventBus}.
     *
     * <p>Unless also annotated with @{@link AllowConcurrentEvents}, event subscriber methods will be
     * invoked serially by each event bus that they are registered with.
     *
     * @author Cliff Biffle
     * @since 10.0
     */
    @Retention(RetentionPolicy.RUNTIME)
    @Target(ElementType.METHOD)
    @Keep
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 15:46:17 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  6. internal/pubsub/pubsub_test.go

    	defer close(doneCh)
    	if err := ps.Subscribe(MaskAll, ch1, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if err := ps.Subscribe(MaskAll, ch2, doneCh, nil); err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	ps.Lock()
    	defer ps.Unlock()
    
    	if len(ps.subs) != 2 || ps.NumSubscribers(MaskAll) != 2 || ps.Subscribers() != 2 {
    		t.Fatalf("expected 2 subscribers")
    	}
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Wed Aug 14 17:11:51 GMT 2024
    - 5.8K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/eventbus/SubscriberTest.java

      }
    
      public void testCreate() {
        Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod"));
        assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class);
    
        // a thread-safe method should not create a synchronized subscriber
        Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod"));
        assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 21:52:12 GMT 2025
    - 4.8K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/eventbus/Dispatcher.java

          private final Object event;
          private final Subscriber subscriber;
    
          private EventWithSubscriber(Object event, Subscriber subscriber) {
            this.event = event;
            this.subscriber = subscriber;
          }
        }
      }
    
      /** Implementation of {@link #immediate()}. */
      private static final class ImmediateDispatcher extends Dispatcher {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 7.4K bytes
    - Click Count (0)
  9. guava-tests/test/com/google/common/eventbus/outside/BaseSubscriberFinderTest.java

    import static com.google.common.truth.Truth.assertThat;
    
    import com.google.common.eventbus.Subscribe;
    import com.google.common.eventbus.outside.BaseSubscriberFinderTest.Subscriber;
    import java.util.ArrayList;
    import java.util.List;
    
    public class BaseSubscriberFinderTest extends AbstractEventBusTest<Subscriber> {
      static class Subscriber {
        final List<Object> nonSubscriberEvents = new ArrayList<>();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 1.5K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/eventbus/SubscriberTest.java

      }
    
      public void testCreate() {
        Subscriber s1 = Subscriber.create(bus, this, getTestSubscriberMethod("recordingMethod"));
        assertThat(s1).isInstanceOf(Subscriber.SynchronizedSubscriber.class);
    
        // a thread-safe method should not create a synchronized subscriber
        Subscriber s2 = Subscriber.create(bus, this, getTestSubscriberMethod("threadSafeMethod"));
        assertThat(s2).isNotInstanceOf(Subscriber.SynchronizedSubscriber.class);
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Dec 26 21:52:12 GMT 2025
    - 4.8K bytes
    - Click Count (0)
Back to Top