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

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

Integer>create(), Functions.<Integer>identity()) L41: .asMap(); L42: } L43: L44: @Override L45: protected Map<String, Collection<Integer>> makePopulatedMap() { L46: ListMultimap<String, Integer> delegate = ArrayListMultimap.create(); L47: populate(delegate); L48: return Multimaps.transformValues(delegate, Functions.<Integer>identity()).asMap(); L49: } L50:}...

L30:final class SingletonImmutableList<E> extends ForwardingImmutableList<E> { L31: L32: final transient List<E> delegate; L33: // This reference is used both by the custom field serializer, and by the L34: // GWT compiler to infer the elements of the lists that needs to be L35: // serialized. L36: E element; L37: L38: SingletonImmutableList(E element) { L39: this.delegate = singletonList(checkNotNull(element)); L40: this.element = element; L41: } L42: L43: @Override L44: List<E>...