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: ...

"scheduled_job"; L65: } L66: L67: @Override L68: public ScheduledJobDbm asDBMeta() { L69: return ScheduledJobDbm.getInstance(); L70: } L71: L72: @Override L73: protected <RESULT extends ScheduledJob> RESULT createEntity(Map<String, Object> source, Class<? extends RESULT> entityType) { L74: try { L75: final RESULT result = entityType.newInstance(); L76: result.setAvailable(DfTypeUtil.toBoolean(source.get("available"))); L77: result.setCrawler...

ssages -> messages.addErrorsCrudFailedToCreateCrudTable(GLOBAL, "doc is required")); L122: } L123: validateFields(body.doc, this::throwValidationErrorApi); L124: body.crudMode = CrudMode.CREATE; L125: final Map<String, Object> doc = getDoc(body).map(entity -> { L126: try { L127: entity.putAll(fessConfig.convertToStorableDoc(body.doc)); L128: L129: final String newId = ComponentUtil.getCrawlingInfoHelper().generateId(entity); L130:...

values L65: * @since 7.0 L66: */ L67:@DoNotMock("Use ImmutableTable, HashBasedTable, or another implementation") L68:@GwtCompatible L69:@ElementTypesAreNonnullByDefault L70:public interface Table< L71: R extends @Nullable Object, C extends @Nullable Object, V extends @Nullable Object> { L72: // TODO(jlevy): Consider adding methods similar to ConcurrentMap methods. L73: L74: // Accessors L75: L76: /** L77: * Returns {@code true} if the table contains a mapping with the specified row and column keys....

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...

return new ByteArrayAsList(array, start + fromIndex, start + toIndex); L332: } L333: L334: @Override L335: public boolean equals(@CheckForNull Object object) { L336: if (object == this) { L337: return true; L338: } L339: if (object instanceof ByteArrayAsList) { L340: ByteArrayAsList that = (ByteArrayAsList) object; L341: int size = size(); L342: if (that.size() != size) { L343: return false; L344: } L345: for (int i = 0; i <...

this.funnel, L278: that.funnel); L279: this.bits.putAll(that.bits); L280: } L281: L282: @Override L283: public boolean equals(@CheckForNull Object object) { L284: if (object == this) { L285: return true; L286: } L287: if (object instanceof BloomFilter) { L288: BloomFilter<?> that = (BloomFilter<?>) object; L289: return this.numHashFunctions == that.numHashFunctions L290: && this.funnel.equals(that.funnel) L291: && this.bits.equals(that.bits)...

E> gen) { L170: this.gen = gen; L171: } L172: L173: @Override L174: public SampleElements<E> samples() { L175: return gen.samples(); L176: } L177: L178: @Override L179: public Set<E> create(Object... elements) { L180: Object[] duplicated = new Object[elements.length * 2]; L181: for (int i = 0; i < elements.length; i++) { L182: duplicated[i] = elements[i]; L183: duplicated[i + elements.length] = elements[i]; L184: } L185: return ((Multiset<E>)...

iately() { L175: webServer.enqueue( L176: MockResponse.Builder() L177: .webSocketUpgrade(serverListener) L178: .build(), L179: ) L180: val e = RuntimeException() L181: clientListener.setNextEventDelegate( L182: object : WebSocketListener() { L183: override fun onOpen( L184: webSocket: WebSocket, L185: response: Response, L186: ) { L187: throw e L188: } L189: }, L190: ) L191: newWebSocket() L192: ser...

L211: L212: private static final class MockEquivalence extends Equivalence<Object> { L213: final ImmutableTable.Builder<Object, Object, Boolean> equivalentExpectationsBuilder = L214: ImmutableTable.builder(); L215: final ImmutableMap.Builder<Object, Integer> hashExpectationsBuilder = ImmutableMap.builder(); L216: ImmutableTable<Object, Object, Boolean> equivalentExpectations; L217: ImmutableMap<Object, Integer> hashExpectations; L218: L219: void expectEquivalent(Object a, Object...