range. If {@code safeMax < safeMin} then no code points are considered safe. L63: * L64: * <p>If a code point has no mapped replacement then it is checked against the safe range. If it L65: * lies outside that, then {@link #escapeUnsafe} is called, otherwise no escaping is performed. L66: * L67: * @param replacementMap a map of characters to their escaped representations L68: * @param safeMin the lowest character value in the safe range L69: * @param safeMax the highest character value...

or values are L373: * not allowed, and will cause {@link #build} to fail. L374: */ L375: @CanIgnoreReturnValue L376: @Override L377: public Builder<K, V> put(K key, V value) { L378: super.put(key, value); L379: return this; L380: } L381: L382: /** L383: * Adds the given {@code entry} to the bimap. Duplicate keys or values are not allowed, and will L384: * cause {@link #build} to fail. L385: * L386: * @since 19.0 L387: */ L388: @CanIgnoreReturnValue...

graph.isDirected() ? new Directed<N>(graph) : new Undirected<N>(graph); L47: } L48: L49: private EndpointPairIterator(BaseGraph<N> graph) { L50: this.graph = graph; L51: this.nodeIterator = graph.nodes().iterator(); L52: } L53: L54: /** L55: * Called after {@link #successorIterator} is exhausted. Advances {@link #node} to the next node L56: * and updates {@link #successorIterator} to iterate through the successors of {@link #node}. L57: */ L58: final boolean advance() { L59: checkStat...

<p>A "lock-like object" is really any object that may be used for concurrency control. If the L40: * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a L41: * method equivalent to {@link java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. If L42: * the {@link #callAndAssertWaits} method is ever called in a test, the lock-like object must have a L43: * method equivalent to {@link L44: * java.util.concurrent.locks.ReentrantLock#hasWaiters(jav...

stream will be open at a time. Closing the concatenated stream will L456: * close the open underlying stream. L457: * L458: * <p>Note: The input {@code Iterator} will be copied to an {@code ImmutableList} when this method L459: * is called. This will fail if the iterator is infinite and may cause problems if the iterator L460: * eagerly fetches data for each source when iterated (rather than producing sources that only L461: * load data through their streams). Prefer using the {@link #concat(Iterable)}...

with {@code node} in L164: * this network. L165: * L166: * <p>This is equal to the union of {@link #predecessors(Object)} and {@link #successors(Object)}. L167: * L168: * <p>If {@code node} is removed from the network after this method is called, the {@code Set} L169: * {@code view} returned by this method will be invalidated, and will throw {@code L170: * IllegalStateException} if it is accessed in any way, with the following exceptions: L171: * L172: * <ul> L173: * <li>{@code...

Assert.assertTrue(countDownLatch.await(1L, SECONDS)); L77: L78: try { L79: future.get(); L80: Assert.fail("This call was supposed to throw an ExecutionException"); L81: } catch (ExecutionException expected) { L82: Assert.assertSame(expectedCause, expected.getCause()); L83: } L84: } L85: L86: public void assertTimeout() throws Exception { L87: // Verify that the listener does not get called in a reasonable amount of L88: // time. L89: Assert.assertFalse(countDownLatch.await(1L, SECONDS));...

not available, it will wait for them up to the specified timeout. L283: * L284: * @param q the blocking queue to be drained L285: * @param buffer where to add the transferred elements L286: * @param numElements the number of elements to be waited for L287: * @param timeout how long to wait before giving up L288: * @return the number of elements transferred L289: * @throws InterruptedException if interrupted while waiting L290: * @since 28.0 (but only since 33.4.0 in the Android flavor)...

void addFieldToSource(final Map<String, Object> sourceMap, final String field, final Object value) { L77: if (value instanceof final LocalDateTime ldt) { L78: final ZonedDateTime zdt = ZonedDateTime.of(ldt, ZoneId.systemDefault()); L79: super.addFieldToSource(sourceMap, field, DateTimeFormatter.ISO_INSTANT.format(zdt)); L80: } else { L81: super.addFieldToSource(sourceMap, field, value); L82: } L83: } L84: L85: @Override L86: public String...

} L329: queryBuilderList.add(builder); L330: } L331: L332: protected void regOBA(String field) { L333: registerOrderBy(field, true); L334: } L335: L336: protected void regOBD(String field) { L337: registerOrderBy(field, false); L338: } L339: L340: protected void registerOrderBy(String field, boolean ascOrDesc) { L341: assertObjectNotNull("field", field); L342: if (fieldSortBuilderList == null) { L343: fieldSortBuilderList = new ArrayList<>();...