} L51: } L52: L53: @Override L54: public boolean contains(@CheckForNull Object obj) { L55: if (!(obj instanceof EndpointPair)) { L56: return false; L57: } L58: EndpointPair<?> endpointPair = (EndpointPair<?>) obj; L59: L60: if (graph.isDirected()) { L61: if (!endpointPair.isOrdered()) { L62: return false; L63: } L64: L65: Object source = endpointPair.source(); L66: Object target = endpointPair.target(); L67: return (node.equals(source) && gra...

final AtomicInteger loadAllCount = new AtomicInteger(); L56: L57: CacheLoader<Object, Object> baseLoader = L58: new CacheLoader<Object, Object>() { L59: @Override L60: public Object load(Object key) { L61: loadCount.incrementAndGet(); L62: return new Object(); L63: } L64: L65: @Override L66: public ListenableFuture<Object> reload(Object key, Object oldValue) { L67: reloadCount.incrementAndGet(); L68: return...

otations.CanIgnoreReturnValue; L23: L24:/** Precondition checks useful in collection implementations. */ L25:@GwtCompatible L26:@ElementTypesAreNonnullByDefault L27:final class CollectPreconditions { L28: L29: static void checkEntryNotNull(Object key, Object value) { L30: if (key == null) { L31: throw new NullPointerException("null key in entry: null=" + value); L32: } else if (value == null) { L33: throw new NullPointerException("null value in entry: " + key + "=null"); L34: ...

(isPrimitiveOrNullable(invokable.getParameters().get(paramIndex))) { L359: return; // there's nothing to test L360: } L361: @Nullable Object[] params = buildParamList(invokable, paramIndex); L362: try { L363: @SuppressWarnings("unchecked") // We'll get a runtime exception if the type is wrong. L364: Invokable<Object, ?> unsafe = (Invokable<Object, ?>) invokable; L365: unsafe.invoke(instance, params); L366: Assert.fail( L367: "No exception thrown for parameter at...

service.shutdown(); L180: } L181: } L182: L183: private ListenerCallQueue.Event<Object> incrementingEvent( L184: Multiset<Object> counters, Object expectedListener, int expectedCount) { L185: return incrementingEvent(counters, multiset(expectedListener, expectedCount)); L186: } L187: L188: private ListenerCallQueue.Event<Object> incrementingEvent( L189: final Multiset<Object> counters, final Multiset<Object> expected) { L190: return new ListenerCallQueue.Event<Object>() { L191: ...

service.shutdown(); L180: } L181: } L182: L183: private ListenerCallQueue.Event<Object> incrementingEvent( L184: Multiset<Object> counters, Object expectedListener, int expectedCount) { L185: return incrementingEvent(counters, multiset(expectedListener, expectedCount)); L186: } L187: L188: private ListenerCallQueue.Event<Object> incrementingEvent( L189: final Multiset<Object> counters, final Multiset<Object> expected) { L190: return new ListenerCallQueue.Event<Object>() { L191: ...

L51:public abstract class ForwardingSet<E extends @Nullable Object> extends ForwardingCollection<E> L52: implements Set<E> { L53: // TODO(lowasser): identify places where thread safety is actually lost L54: L55: /** Constructor for use by subclasses. */ L56: protected ForwardingSet() {} L57: L58: @Override L59: protected abstract Set<E> delegate(); L60: L61: @Override L62: public boolean equals(@CheckForNull Object object) { L63: return object == this || delegate().equals(object); L64: } L65:...

L142: @GwtIncompatible // serialization L143: Object writeReplace() { L144: return super.writeReplace(); L145: } L146: }; L147: } L148: L149: @Override L150: public int size() { L151: return axesSizeProduct[0]; L152: } L153: L154: @Override L155: public boolean contains(@CheckForNull Object object) { L156: if (!(object instanceof List)) { L157: return false; L158: } L159: List<?> list = (List<?>) object; L160: if (list.size() != axes.size()) { L161: ...

Iterators.size(registry.getSubscribers(""))); L86: assertEquals(1, Iterators.size(registry.getSubscribers(new Object()))); L87: assertEquals(1, Iterators.size(registry.getSubscribers(1))); L88: L89: registry.register(new IntegerSubscriber()); L90: assertEquals(3, Iterators.size(registry.getSubscribers(""))); L91: assertEquals(1, Iterators.size(registry.getSubscribers(new Object()))); L92: assertEquals(2, Iterators.size(registry.getSubscribers(1))); L93: } L94: L95: public void te...

List<Object> annotatedIn1And2Events = Lists.newArrayList(); L66: final List<Object> annotatedIn1And2AndClassEvents = Lists.newArrayList(); L67: final List<Object> declaredIn1AnnotatedIn2Events = Lists.newArrayList(); L68: final List<Object> declaredIn1AnnotatedInClassEvents = Lists.newArrayList(); L69: final List<Object> declaredIn2AnnotatedInClassEvents = Lists.newArrayList(); L70: final List<Object> annotatedIn2Events = Lists.newArrayList(); L71: final List<Object> nowhereAnnotatedEvents...