} L329: queryBuilderList.add(builder); L330: } L331: L332: protected void regOBA(String field) { L333: registerOrderBy(field, true); L334: } L335: L336: protected void regOBD(String field) { L337: registerOrderBy(field, false); L338: } L339: L340: protected void registerOrderBy(String field, boolean ascOrDesc) { L341: assertObjectNotNull("field", field); L342: if (fieldSortBuilderList == null) { L343: fieldSortBuilderList = new ArrayList<>();...

kinds of methods: L37: * L38: * <ul> L39: * <li><b>Methods that return a writer:</b> These methods should return a <i>new</i>, independent L40: * instance each time they are called. The caller is responsible for ensuring that the L41: * returned writer is closed. L42: * <li><b>Convenience methods:</b> These are implementations of common operations that are L43: * typically implemented by opening a writer using one of the methods in the first category, L44: * doing something...

* range. If {@code safeMax < safeMin} then no characters are considered safe. L58: * L59: * <p>If a character has no mapped replacement then it is checked against the safe range. If it L60: * lies outside that, then {@link #escapeUnsafe} is called, otherwise no escaping is performed. L61: * L62: * @param replacementMap a map of characters to their escaped representations L63: * @param safeMin the lowest character value in the safe range L64: * @param safeMax the highest character value...

L18:import okio.IOException L19: L20:interface Callback { L21: /** L22: * Called when the request could not be executed due to cancellation, a connectivity problem or L23: * timeout. Because networks can fail during an exchange, it is possible that the remote server L24: * accepted the request before the failure. L25: */ L26: fun onFailure( L27: call: Call, L28: e: IOException, L29: ) L30: L31: /** L32: * Called when the HTTP response was successfully returned by the remote server....

not available, it will wait for them up to the specified timeout. L283: * L284: * @param q the blocking queue to be drained L285: * @param buffer where to add the transferred elements L286: * @param numElements the number of elements to be waited for L287: * @param timeout how long to wait before giving up L288: * @return the number of elements transferred L289: * @throws InterruptedException if interrupted while waiting L290: * @since NEXT (but since 28.0 in the JRE flavor) L291:...

L166: /** L167: * Simulate some of the races that can happen on add. We can't easily simulate the race that L168: * happens when an {@link AtomicInteger#compareAndSet} fails, but we can simulate the case where L169: * the putIfAbsent returns a non-null value, and the case where the replace() of an observed zero L170: * fails. L171: */ L172: public void testAdd_withFailures() { L173: AtomicInteger existing = new AtomicInteger(12); L174: AtomicInteger existingZero = new AtomicInteger(0);...

L1:public final class okhttp3/dnsoverhttps/DnsOverHttps : okhttp3/Dns { L2: public static final field Companion Lokhttp3/dnsoverhttps/DnsOverHttps$Companion; L3: public static final field MAX_RESPONSE_SIZE I L4: public final fun client ()Lokhttp3/OkHttpClient; L5: public final fun includeIPv6 ()Z L6: public fun lookup (Ljava/lang/String;)Ljava/util/List; L7: public final fun post ()Z L8: public final fun resolvePrivateAddresses ()Z L9: public final fun resolvePublicAddresses ()Z L10: public final...

either express or implied. L13: * See the License for the specific language governing permissions and L14: * limitations under the License. L15: */ L16: L17:package com.google.common.collect; L18: L19:import static java.lang.annotation.ElementType.FIELD; L20:import static java.lang.annotation.RetentionPolicy.RUNTIME; L21: L22:import com.google.common.annotations.GwtCompatible; L23:import java.lang.annotation.Documented; L24:import java.lang.annotation.Retention; L25:import java.lang.annotation.Target;...

pos - start); L77: finishLine(true); L78: start = pos + 1; L79: break; L80: L81: default: L82: // do nothing L83: } L84: } L85: line.append(cbuf, start, off + len - start); L86: } L87: L88: /** Called when a line is complete. */ L89: @CanIgnoreReturnValue L90: private boolean finishLine(boolean sawNewline) throws IOException { L91: String separator = sawReturn ? (sawNewline ? "\r\n" : "\r") : (sawNewline ? "\n" : ""); L92: handleLine(line.toString(),...

pos - start); L77: finishLine(true); L78: start = pos + 1; L79: break; L80: L81: default: L82: // do nothing L83: } L84: } L85: line.append(cbuf, start, off + len - start); L86: } L87: L88: /** Called when a line is complete. */ L89: @CanIgnoreReturnValue L90: private boolean finishLine(boolean sawNewline) throws IOException { L91: String separator = sawReturn ? (sawNewline ? "\r\n" : "\r") : (sawNewline ? "\n" : ""); L92: handleLine(line.toString(),...