Job.class); L24: L25: private long expiry = 30 * 24 * 60 * 60 * 1000L; L26: L27: public String execute() { L28: try { L29: final long count = ComponentUtil.getThumbnailManager().purge(getExpiry()); L30: return "Deleted " + count + " thumbnail files."; L31: } catch (final Exception e) { L32: logger.error("Failed to purge thumbnails.", e); L33: return e.getMessage(); L34: } L35: } L36: L37: public long getExpiry() { L38: ...

ex() L44: assertThat(inflater.inflate(message)).isEqualTo("22021002".decodeHex()) L45: } L46: L47: @Test fun `deflate golden value`() { L48: val deflater = MessageDeflater(false) L49: val deflated = deflater.deflate("Hello deflate!".encodeUtf8()) L50: assertThat(deflated.hex()).isEqualTo("f248cdc9c95748494dcb492c49550400") L51: } L52: L53: @Test fun `inflate deflate`() { L54: val deflater = MessageDeflater(false) L55: val inflater = MessageInflater(false) L56: L57: val goldenValue...

L22:/** L23: * A sink that executes [trigger] after [triggerByteCount] bytes are written, and then skips all L24: * subsequent bytes. L25: */ L26:internal class TriggerSink( L27: private val delegate: Sink, L28: private val triggerByteCount: Long, L29: private val trigger: () -> Unit, L30:) : Sink by delegate { L31: private var bytesWritten = 0L L32: L33: override fun write( L34: source: Buffer, L35: byteCount: Long, L36: ) { L37: if (byteCount == 0L) return // Avoid double-triggering....

return ImmutableSetMultimap.<String, Integer>of().asMap(); L41: } L42: L43: @Override L44: protected Map<String, Collection<Integer>> makePopulatedMap() { L45: Multimap<String, Integer> delegate = HashMultimap.create(); L46: populate(delegate); L47: return ImmutableSetMultimap.copyOf(delegate).asMap(); L48: } L49:}...

.createTestSuite(); L114: } L115: L116: /** Like using() but overrideable by NavigableSetTestSuiteBuilder. */ L117: SortedSetTestSuiteBuilder<E> newBuilderUsing( L118: TestSortedSetGenerator<E> delegate, Bound to, Bound from) { L119: return using(new SortedSetSubsetTestSetGenerator<E>(delegate, to, from)); L120: } L121:}...

.createTestSuite(); L114: } L115: L116: /** Like using() but overrideable by NavigableSetTestSuiteBuilder. */ L117: SortedSetTestSuiteBuilder<E> newBuilderUsing( L118: TestSortedSetGenerator<E> delegate, Bound to, Bound from) { L119: return using(new SortedSetSubsetTestSetGenerator<E>(delegate, to, from)); L120: } L121:}...

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: L66: @Override L67: public int hashCode() { L68: return delegate().hashCode(); L69: } L70: L71: /** L72: * A sensible definition of {@link #removeAll} in terms of {@link #iterator} and {@link #remove}....

/** A wrapped future that does not propagate cancellation to its delegate. */ L803: private static final class NonCancellationPropagatingFuture<V extends @Nullable Object> L804: extends AbstractFuture.TrustedFuture<V> implements Runnable { L805: @CheckForNull @LazyInit private ListenableFuture<V> delegate; L806: L807: NonCancellationPropagatingFuture(final ListenableFuture<V> delegate) { L808: this.delegate = delegate; L809: } L810: L811: @Override L812: public void run()...

parentBuilder, L114: Bound from, L115: Bound to) { L116: TestSortedMapGenerator<K, V> delegate = L117: (TestSortedMapGenerator<K, V>) parentBuilder.getSubjectGenerator().getInnerGenerator(); L118: L119: List<Feature<?>> features = new ArrayList<>(); L120: features.add(NoRecurse.SUBMAP); L121: features.addAll(parentBuilder.getFeatures()); L122: L123: return newBuilderUsing(delegate, to, from) L124: .named(parentBuilder.getName() + " subMap " + from + "-" + to) L125:...

L40: return ImmutableMultimap.<String, Integer>of().asMap(); L41: } L42: L43: @Override L44: protected Map<String, Collection<Integer>> makePopulatedMap() { L45: Multimap<String, Integer> delegate = HashMultimap.create(); L46: populate(delegate); L47: return ImmutableMultimap.copyOf(delegate).asMap(); L48: } L49:}...