- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 154 for selectend (0.05 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt
else -> addresses } for (inetAddress in orderedAddresses) { mutableInetSocketAddresses += InetSocketAddress(inetAddress, socketPort) } } } /** A set of selected Routes. */ class Selection( val routes: List<Route>, ) { private var nextRouteIndex = 0 operator fun hasNext(): Boolean = nextRouteIndex < routes.size operator fun next(): Route {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 7.3K bytes - Viewed (1) -
.teamcity/src/main/kotlin/model/CIBuildModel.kt
val maxParallelForks: Int = 4, ) { // Include cross version tests, these take care of selecting a very small set of versions to cover when run as part of this stage, including the current version QUICK(true, true, true, 120, 4), // Include cross version tests, these take care of selecting a very small set of versions to cover when run as part of this stage, including the current version
Registered: Wed Sep 10 11:36:15 UTC 2025 - Last Modified: Sun Aug 03 22:40:28 UTC 2025 - 25.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* // processing the RPC to fetch counters. * ListenableFuture<Integer> faultTolerantFuture = Futures.catching( * fetchCounterFuture, FetchException.class, x -> 0, directExecutor()); * } * * <p>When selecting an executor, note that {@code directExecutor} is dangerous in some cases. See * the warnings the {@link MoreExecutors#directExecutor} documentation. * * @param input the primary input {@code Future}
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/resolver/DefaultLegacyArtifactCollector.java
// Select an appropriate available version from the (now restricted) range // Note this version was selected before to get the appropriate POM // But it was reset by the call to setVersionRange on restricting the version ResolutionNode[] resetNodes = {previous, node};
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 36.5K bytes - Viewed (0) -
src/main/webapp/js/suggestor.js
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Mar 30 05:45:24 UTC 2023 - 13.3K bytes - Viewed (0) -
cmd/admin-heal-ops.go
return nil } // healSequenceStart - this is the top-level background heal // routine. It launches another go-routine that actually traverses // on-disk data, checks and heals according to the selected // settings. This go-routine itself, (1) monitors the traversal // routine for completion, and (2) listens for external stop // signals. When either event happens, it sets the finish status for // the heal-sequence.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 25.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt
* * ## The buffer * * In this case the bytes are immediately copied into [sink] and the number of bytes copied is * returned. * * If upstream would be selected but another thread is already reading upstream this will * block until that read completes. It is possible to time out while waiting for that. */ @Throws(IOException::class) override fun read(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 17:15:47 UTC 2025 - 11.8K bytes - Viewed (0) -
fess-crawler/src/test/resources/ajax/js/jquery-2.1.1.min.js
typeof b.getElementsByClassName!==C&&p?b.getElementsByClassName(a):void 0},r=[],q=[],(c.qsa=$.test(e.querySelectorAll))&&(ib(function(a){a.innerHTML="<select msallowclip=''><option selected=''></option></select>",a.querySelectorAll("[msallowclip^='']").length&&q.push("[*^$]="+M+"*(?:''|\"\")"),a.querySelectorAll("[selected]").length||q.push("\\["+M+"*(?:value|"+L+")"),a.querySelectorAll(":checked").length||q.push(":checked")}),ib(function(a){var b=e.createElement("input");b.setAttribute("type","hid...
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Oct 11 02:16:55 UTC 2015 - 82.3K bytes - Viewed (0) -
docs/smb3-features/03-multi-channel-design.md
// Large transfer should prefer high-bandwidth channel Smb2ReadRequest largeRead = new Smb2ReadRequest(); largeRead.setLength(10485760); // 10MB ChannelInfo selected = balancer.selectChannel(largeRead); assertEquals(channel2, selected); // Should select 10Gbps channel } @Test public void testChannelFailover() throws Exception { ChannelManager manager = new ChannelManager(context, session);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 39.6K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/FeatureSpecificTestSuiteBuilder.java
import junit.framework.TestCase; import junit.framework.TestSuite; import org.jspecify.annotations.Nullable; /** * Creates, based on your criteria, a JUnit test suite that exhaustively tests the object generated * by a G, selecting appropriate tests by matching them against specified features. * * @param <B> The concrete type of this builder (the 'self-type'). All the Builder methods of this
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 10.4K bytes - Viewed (0)