- Sort Score
- Num 10 results
- Language All
Results 361 - 370 of 610 for necessarily (0.06 seconds)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
@Throws(IOException::class) fun nextPart(): Part? { check(!closed) { "closed" } if (noMoreParts) return null // Read a boundary, skipping the remainder of the preceding part as necessary. if (partCount == 0 && source.rangeEquals(0L, dashDashBoundary)) { // This is the first part. Consume "--" followed by the boundary. source.skip(dashDashBoundary.size.toLong()) } else {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Jan 27 09:00:39 GMT 2026 - 7.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt
} /** Prepares the socket addresses to attempt for the current proxy or host. */ @Throws(IOException::class) private fun resetNextInetSocketAddress(proxy: Proxy) { // Clear the addresses. Necessary if getAllByName() below throws! val mutableInetSocketAddresses = mutableListOf<InetSocketAddress>() inetSocketAddresses = mutableInetSocketAddresses val socketHost: String val socketPort: Int
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Oct 08 03:50:05 GMT 2025 - 7.3K bytes - Click Count (2) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
} } /** * Records the given exception using {@link #threadRecordFailure}, then rethrows the exception, * wrapping it in an AssertionFailedError if necessary. */ final void threadUnexpectedException(Throwable t) { threadRecordFailure(t); t.printStackTrace(); if (t instanceof RuntimeException) { throw (RuntimeException) t;Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Sat Mar 07 02:20:33 GMT 2026 - 8.8K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/ContiguousSet.java
*/ C afterLower = requireNonNull(range.lowerBound.leastValueAbove(domain)); C beforeUpper = requireNonNull(range.upperBound.greatestValueBelow(domain)); // Per class spec, we are allowed to throw CCE if necessary empty = Range.compareOrThrow(afterLower, beforeUpper) > 0; } return empty ? new EmptyContiguousSet<C>(domain) : new RegularContiguousSet<C>(effectiveRange, domain); } /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Aug 07 16:05:33 GMT 2025 - 9.9K bytes - Click Count (0) -
futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java
* can't get by with the standard implementations, prefer to derive a new {@code Future} instance * with the methods in {@link Futures} or, if necessary, to extend {@link AbstractFuture}. * * <p>Occasionally, an API will return a plain {@code Future} and it will be impossible to change * the return type. For this case, we provide a more expensive workaround in {@code
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Jan 29 22:14:05 GMT 2026 - 8K bytes - Click Count (0) -
android/guava/src/com/google/common/io/Files.java
} } /** * Creates any necessary but nonexistent parent directories of the specified file. Note that if * this operation fails it may have succeeded in creating some (but not all) of the necessary * parent directories. * * @throws IOException if an I/O error occurs, or if any necessary but nonexistent parent * directories of the specified file could not be created.
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Jan 05 22:13:21 GMT 2026 - 32.8K bytes - Click Count (0) -
src/main/java/jcifs/internal/smb2/Smb2TransformHeader.java
package jcifs.internal.smb2; import jcifs.Encodable; import jcifs.internal.util.SMBUtil; /** * SMB2 Transform Header for encrypted messages * * This header is used to encrypt SMB2/SMB3 messages and provides the necessary * cryptographic parameters for decryption including the nonce, session ID, and * authentication tag. * * @author mbechler */ public class Smb2TransformHeader implements Encodable { /**Created: Sun Apr 05 00:10:12 GMT 2026 - Last Modified: Sat Aug 30 05:58:03 GMT 2025 - 9.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(pool.closeConnections(150L)).isEqualTo(0) assertThat(pool.connectionCount()).isEqualTo(0) assertThat(c1.socket().isClosed).isTrue() // Running again, the pool reports that no further runs are necessary. assertThat(pool.closeConnections(150L)).isEqualTo(-1) assertThat(pool.connectionCount()).isEqualTo(0) assertThat(c1.socket().isClosed).isTrue() } @Test fun inUseConnectionsNotEvicted() {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 8.2K bytes - Click Count (0) -
guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSet.java
default: return new RegularImmutableSet<E>(delegate); } } private static <E> ImmutableSet<E> create(E... elements) { // Create the set first, to remove duplicates if necessary. Set<E> set = Sets.newLinkedHashSet(); Collections.addAll(set, elements); for (E element : set) { checkNotNull(element); } switch (set.size()) { case 0:Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Sep 22 21:07:18 GMT 2025 - 8.2K bytes - Click Count (0) -
internal/config/identity/ldap/config.go
l.LDAP.GroupSearchFilter = getCfgVal(GroupSearchFilter) l.LDAP.GroupSearchBaseDistName = getCfgVal(GroupSearchBaseDN) // If enable flag was not explicitly set, we treat it as implicitly set at // this point as necessary configuration is available. if !isEnableFlagExplicitlySet && !l.LDAP.Enabled { l.LDAP.Enabled = true } // Validate and test configuration. valResult := l.LDAP.Validate() if !valResult.IsOk() {
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Sep 18 11:47:48 GMT 2025 - 8.6K bytes - Click Count (0)