charset, this will use UTF-8. L107: */ L108: @JvmStatic L109: @JvmName("create") L110: fun String.toRequestBody(contentType: MediaType? = null): RequestBody { L111: val (charset, finalContentType) = contentType.chooseCharset() L112: val bytes = toByteArray(charset) L113: return bytes.toRequestBody(finalContentType, 0, bytes.size) L114: } L115: L116: @JvmStatic L117: @JvmName("create") L118: fun ByteString.toRequestBody(contentType: MediaType? = null): RequestBody...

this.generator = oneSizeTestContainerGenerator; L55: } L56: L57: @Override L58: public SampleElements<Entry<K, V>> samples() { L59: return generator.samples(); L60: } L61: L62: @Override L63: public Map<K, V> create(Object... elements) { L64: return generator.create(elements); L65: } L66: L67: @Override L68: public Entry<K, V>[] createArray(int length) { L69: return generator.createArray(length); L70: } L71: L72: @Override L73: public Iterable<Entry<K, V>> order(List<Entry<K,...

V> { L61: // TODO(lowasser): implement removeEldestEntry so this can be used as a drop-in replacement L62: L63: /** Creates an empty {@code CompactLinkedHashMap} instance. */ L64: public static <K extends @Nullable Object, V extends @Nullable Object> L65: CompactLinkedHashMap<K, V> create() { L66: return new CompactLinkedHashMap<>(); L67: } L68: L69: /** L70: * Creates a {@code CompactLinkedHashMap} instance, with a high enough "initial capacity" that it L71: * <i>should</i> hold {@code...

new EqualsTester() L37: .addEqualityGroup( L38: getMultiset(), getSubjectGenerator().create(getSampleElements().toArray())) L39: .testEquals(); L40: } L41: L42: @CollectionSize.Require(absent = ZERO) L43: public void testNotEqualsEmpty() { L44: new EqualsTester() L45: .addEqualityGroup(getMultiset()) L46: .addEqualityGroup(getSubjectGenerator().create()) L47: .testEquals(); L48: } L49: L50: public void testHashCodeMatchesEntrySet() { L51: a...

====================== L368: @Override L369: public ColumnRealName toColumnRealName(String columnDbName) { L370: return ColumnRealName.create(xgetAliasName(), toColumnSqlName(columnDbName)); L371: } L372: L373: @Override L374: public ColumnRealName toColumnRealName(ColumnInfo columnInfo) { L375: return ColumnRealName.create(xgetAliasName(), columnInfo.getColumnSqlName()); L376: } L377: L378: @Override L379: public ColumnSqlName toColumnSqlName(String columnDbName)...

ear(shadowLoaderReference); L89: } L90: L91: // Create a second ClassLoader and use it to get a second version of the TestEnum class. L92: // Run Enums.getIfPresent on that other TestEnum and then return a WeakReference containing the L93: // new ClassLoader. If Enums.getIfPresent does caching that prevents the shadow TestEnum L94: // (and therefore its ClassLoader) from being unloaded, then this WeakReference will never be L95: // cleared. L96: @J2ktIncompatible L97: @GwtIncompatible //...

L167: * that are not the first to be added or last to be removed for their key. L168: */ L169: private transient int modCount; L170: L171: /** Creates a new, empty {@code LinkedListMultimap} with the default initial capacity. */ L172: public static <K extends @Nullable Object, V extends @Nullable Object> L173: LinkedListMultimap<K, V> create() { L174: return new LinkedListMultimap<>(); L175: } L176: L177: /** L178: * Constructs an empty {@code LinkedListMultimap} with enough capacity...

release resources held by this web socket, discarding any enqueued L111: * messages. This does nothing if the web socket has already been closed or canceled. L112: */ L113: fun cancel() L114: L115: fun interface Factory { L116: /** L117: * Creates a new web socket and immediately returns it. Creating a web socket initiates an L118: * asynchronous process to connect the socket. Once that succeeds or fails, `listener` will be L119: * notified. The caller must either close or cancel the...

length: Int, L461: ) L462: L463: /** L464: * Create or update incoming headers, creating the corresponding streams if necessary. Frames L465: * that trigger this are HEADERS and PUSH_PROMISE. L466: * L467: * @param inFinished true if the sender will not send further frames. L468: * @param streamId the stream owning these headers. L469: * @param associatedStreamId the stream that triggered the sender to create this stream. L470: */ L471: fun headers( L472: ...

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