FluentFuture.from(immediateFuture("a")); L65: final boolean[] called = new boolean[1]; L66: f.addCallback( L67: new FutureCallback<String>() { L68: @Override L69: public void onSuccess(String result) { L70: called[0] = true; L71: } L72: L73: @Override L74: public void onFailure(Throwable t) {} L75: }, L76: directExecutor()); L77: assertThat(called[0]).isTrue(); L78: } L79: L80: // Avoid trouble with automatic...

Map<String, Long> queryCountMap = new LinkedHashMap<>(); L33: L34: protected List<Field> fieldList = new ArrayList<>(); L35: L36: public FacetResponse(final Aggregations aggregations) { L37: aggregations.forEach(aggregation -> { L38: if (aggregation.getName().startsWith(Constants.FACET_FIELD_PREFIX)) { L39: final Terms termFacet = (Terms) aggregation; L40: fieldList.add(new Field(termFacet)); L41: } else if (aggregation.getName().startsWith(C...

based on the atomic state in our base class. The L65: * initial write to timer is never definitely visible to Fire.run since it is assigned after L66: * SES.schedule is called. Therefore Fire.run has to check for null. However, it should be visible L67: * if Fire.run is called by delegate.addListener since addListener is called after the assignment L68: * to timer, and importantly this is the main situation in which we need to be able to see the L69: * write. L70: * L71: * 2. visibility...

{@code readLines} methods. L25: * L26: * <p>{@link #processLine} will be called for each line that is read, and should return {@code L27: * false} when you want to stop processing. L28: * L29: * @author Miles Barr L30: * @since 1.0 L31: */ L32:@J2ktIncompatible L33:@GwtIncompatible L34:@ElementTypesAreNonnullByDefault L35:public interface LineProcessor<T extends @Nullable Object> { L36: L37: /** L38: * This method will be called once for each line. L39: * L40: * @param line the line read from...

L562:an hour or so, and were quite dry again, the Dodo suddenly called L563:out `The race is over!' and they all crowded round it, panting, L564:and asking, `But who has won?' L565: L566: This question the Dodo could not answer without a great deal of L567:thought, and it sat for a long time with one finger pressed upon L568:its forehead (the position in which you usually see Shakespeare, L569:in the pictures of him), while the rest waited in silence. At L570:last the Dodo said, `EVERYBODY has won,...

propertyName); // synchronize if exists, basically for user's manual call L89: } L90: L91: public void modifiedToSpecified() { L92: if (__modifiedProperties.isEmpty()) { L93: return; // basically no way when called in Framework (because called when SpecifyColumn exists) L94: } L95: __specifiedProperties = newModifiedProperties(); L96: __specifiedProperties.accept(__modifiedProperties); L97: } L98: L99: // ========================================...

1.0 L31: */ L32:@GwtCompatible(emulated = true) L33:@ElementTypesAreNonnullByDefault L34:public final class Callables { L35: private Callables() {} L36: L37: /** Creates a {@code Callable} which immediately returns a preset value each time it is called. */ L38: public static <T extends @Nullable Object> Callable<T> returning(@ParametricNullness T value) { L39: return () -> value; L40: } L41: L42: /** L43: * Creates an {@link AsyncCallable} from a {@link Callable}. L44: * L45: * <p>The...

buildChainingFuture(inputFuture); L48: listener = new MockFutureListener(resultFuture); L49: } L50: L51: public void testFutureGetBeforeCallback() throws Exception { L52: // Verify that get throws a timeout exception before the callback is called. L53: assertThrows(TimeoutException.class, () -> resultFuture.get(1L, MILLISECONDS)); L54: } L55: L56: public void testFutureGetThrowsWrappedException() throws Exception { L57: inputFuture.setException(EXCEPTION); L58: listener.assertE...

order of the returned map is the order in which entries were L634: * inserted into the builder, unless {@link #orderEntriesByValue} was called, in which case L635: * entries are sorted by value. If a key was added more than once, it appears in iteration order L636: * based on the first time it was added, again unless {@link #orderEntriesByValue} was called. L637: * L638: * <p>In the current implementation, all values associated with a given key are stored in the L639: * {@code...

propertyName); // synchronize if exists, basically for user's manual call L89: } L90: L91: public void modifiedToSpecified() { L92: if (__modifiedProperties.isEmpty()) { L93: return; // basically no way when called in Framework (because called when SpecifyColumn exists) L94: } L95: __specifiedProperties = newModifiedProperties(); L96: __specifiedProperties.accept(__modifiedProperties); L97: } L98: L99: // ========================================...