weaklyReferenceQueue(); L86: GcFinalization.awaitClear(queueReference); L87: } L88: L89: /** If we don't keep a strong reference to the reference object, it won't be enqueued. */ L90: @Nullable FinalizableWeakReference<Object> reference; L91: L92: /** Create the FRQ in a method that goes out of scope so that we're sure it will be reclaimed. */ L93: private void weaklyReferenceQueue() { L94: frq = new FinalizableReferenceQueue(); L95: queueReference = new WeakReference<>(frq.queue); L96: L97: ...

That happens L103: // in our test environment, which foils the purpose of this test, so we disable the logic for L104: // our test by setting a static field. We are changing the field in the parallel version of FRQ L105: // and each test creates its own one of those, so there is no test interference here. L106: Class<?> sepFrqSystemLoaderC = L107: sepLoader.loadClass(FinalizableReferenceQueue.SystemLoader.class.getName()); L108: Field disabled = sepFrqSystemLoaderC.getDeclar...

AbstractContiguousSetGenerator { L377: @Override L378: protected SortedSet<Integer> create(Integer[] elements) { L379: SortedSet<Integer> set = nullCheckedTreeSet(elements); L380: if (set.isEmpty()) { L381: /* L382: * The (tooLow + 1, tooHigh) arguments below would be invalid because tooLow would be L383: * greater than tooHigh. L384: */ L385: return ContiguousSet.create(Range.openClosed(0, 1), DiscreteDomain.integers()).subSet(0, 1); L386: } L387:...

property is used to ensure that no subscriber method is registered more than once. L32: * L33: * @author Colin Decker L34: */ L35:@ElementTypesAreNonnullByDefault L36:class Subscriber { L37: L38: /** Creates a {@code Subscriber} for {@code method} on {@code listener}. */ L39: static Subscriber create(EventBus bus, Object listener, Method method) { L40: return isDeclaredThreadSafe(method) L41: ? new Subscriber(bus, listener, method) L42: : new SynchronizedSubscriber(bus, listener,...

ConfigType.FILE.getConfigId(getId()); L144: } L145: L146: @Override L147: public CrawlerClientFactory initializeClientFactory(final Supplier<CrawlerClientFactory> creator) { L148: if (crawlerClientFactory != null) { L149: return crawlerClientFactory; L150: } L151: final CrawlerClientFactory factory = creator.get(); L152: L153: final FileAuthenticationService fileAuthenticationService = ComponentUtil.getComponent(FileAuthenticationService.class); L154: L155: ...

@Override L249: public Iterable<Entry<K, V>> order(List<Entry<K, V>> insertionOrder) { L250: return mapGenerator.order(insertionOrder); L251: } L252: L253: @Override L254: public Map<K, V> create(Object... elements) { L255: return SerializableTester.reserialize(mapGenerator.create(elements)); L256: } L257: L258: @Override L259: public K[] createKeyArray(int length) { L260: return ((TestMapGenerator<K, V>) mapGenerator.getInnerGenerator()).createKeyArray(length); L261:...

L45: public static class ImmutableListOfGenerator extends TestStringListGenerator { L46: @Override L47: protected List<String> create(String[] elements) { L48: return ImmutableList.copyOf(elements); L49: } L50: } L51: L52: public static class BuilderAddListGenerator extends TestStringListGenerator { L53: @Override L54: protected List<String> create(String[] elements) { L55: ImmutableList.Builder<String> builder = ImmutableList.<String>builder(); L56: for (String element...

extends Throwable> temp = new ArrayList<>(exceptions); L72: this.exceptions = Collections.unmodifiableCollection(temp); L73: } L74: L75: /** See {@link #create(Collection)}. */ L76: static RuntimeException create(Throwable... exceptions) { L77: ArrayList<Throwable> temp = new ArrayList<>(Arrays.asList(exceptions)); L78: return create(temp); L79: } L80: L81: /** L82: * Given a collection of exceptions, returns a {@link RuntimeException}, with the following rules: L83: * L84: * <ul>...

L79: * @since 14.0 L80: */ L81:// Coffee's for {@link Closer closers} only. L82:@J2ktIncompatible L83:@GwtIncompatible L84:@ElementTypesAreNonnullByDefault L85:public final class Closer implements Closeable { L86: /** Creates a new {@link Closer}. */ L87: public static Closer create() { L88: return new Closer(SUPPRESSING_SUPPRESSOR); L89: } L90: L91: @VisibleForTesting final Suppressor suppressor; L92: L93: // only need space for 2 elements in most cases, so try to use the smallest array possible...

public static final fun create (Lokhttp3/MediaType;Lokio/ByteString;)Lokhttp3/RequestBody; L1099: public static final fun create (Lokhttp3/MediaType;[B)Lokhttp3/RequestBody; L1100: public static final fun create (Lokhttp3/MediaType;[BI)Lokhttp3/RequestBody; L1101: public static final fun create (Lokhttp3/MediaType;[BII)Lokhttp3/RequestBody; L1102: public static final fun create (Lokio/ByteString;Lokhttp3/MediaType;)Lokhttp3/RequestBody; L1103: public static final fun create (Lokio/Path;Lokio/File...