- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 487 for our (0.1 sec)
-
guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
.build(); private static final Executor defaultAdapterExecutor = Executors.newCachedThreadPool(threadFactory); private final Executor adapterExecutor; // The execution list to hold our listeners. private final ExecutionList executionList = new ExecutionList(); // This allows us to only start up a thread waiting on the delegate future when the first // listener is added.
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Dec 14 20:35:03 UTC 2023 - 7.5K bytes - Viewed (0) -
.github/ISSUE_TEMPLATE/bug_report.md
--- name: Bug report about: Create a report to help us improve title: '' labels: community, triage assignees: '' --- ## NOTE If this case is urgent, please subscribe to [Subnet](https://min.io/pricing) so that our 24/7 support team may help you faster. <!--- Provide a general summary of the issue in the Title above --> ## Expected Behavior <!--- If you're describing a bug, tell us what should happen -->
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Jan 20 17:37:40 UTC 2022 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-MediaTypeCommon.kt
s = parameter.range.last + 1 continue } val token = parameter.groups[2]?.value val value = when { token == null -> { // Value is "double-quoted". That's valid and our regex group already strips the quotes. parameter.groups[3]!!.value } token.startsWith("'") && token.endsWith("'") && token.length > 2 -> {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.1K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
mockWebServer.dispatcher = dispatcher val url = mockWebServer.url("/").toUrl() val conn = url.openConnection() as HttpURLConnection conn.responseCode // Force the connection to hit the "server". // Make sure our dispatcher got the request. assertThat(requestsMade.size).isEqualTo(1) } @Test fun outOfOrderResponses() { val firstResponseCode = AtomicInteger() val secondResponseCode = AtomicInteger()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.3K bytes - Viewed (0) -
guava/src/com/google/common/collect/AbstractBiMap.java
} @Override public @Nullable Object[] toArray() { return standardToArray(); } @Override @SuppressWarnings("nullness") // bug in our checker's handling of toArray signatures public <T extends @Nullable Object> T[] toArray(T[] array) { return standardToArray(array); } @Override public String toString() {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Aug 24 01:40:03 UTC 2023 - 14.6K bytes - Viewed (0) -
.github/PULL_REQUEST_TEMPLATE.md
<!-- Thanks for sending a pull request! Here are some tips for you: 1. If this is your first time, please read our contributor guidelines: https://git.k8s.io/community/contributors/guide/first-contribution.md#your-first-contribution and developer guide https://git.k8s.io/community/contributors/devel/development.md#development-guide
Registered: Fri Nov 01 09:05:11 UTC 2024 - Last Modified: Sun Aug 01 08:59:21 UTC 2021 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/OpenJSSEPlatform.kt
*/ class OpenJSSEPlatform private constructor() : Platform() { private val provider: Provider = org.openjsse.net.ssl.OpenJSSE() // Selects TLSv1.3 so we are specific about our intended version ranges (not just 1.3) // and because it's a common pattern for VMs to have differences between supported and // defaulted versions for TLS based on what is requested.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3.6K bytes - Viewed (0) -
cni/pkg/nodeagent/cni-watcher_test.go
types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) client.RunAndWait(ctx.Done()) payload, _ := json.Marshal(valid) // serialize our fake plugin event addEvent, err := processAddEvent(payload) assert.Equal(t, err, nil) // Push it thru the handler pluginServer.ReconcileCNIAddEvent(ctx, addEvent) waitForMockCalls()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/MapMakerTest.java
MapMaker maker = new MapMaker(); assertThrows(IllegalArgumentException.class, () -> maker.initialCapacity(-1)); } // TODO(cpovirk): enable when ready (apparently after a change to our GWT emulation) public void xtestInitialCapacity_setTwice() { MapMaker maker = new MapMaker().initialCapacity(16); try { // even to the same value is not allowed maker.initialCapacity(16); fail();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Oct 15 17:36:06 UTC 2024 - 2.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java
* maxPermits is equal to warmupPeriod. * <li>When _used_, the time it takes, as explained in the introductory class note, is equal to * the integral of our function, between X permits and X-K permits, assuming we want to * spend K saved permits. * </ol> * * <p>In summary, the time it takes to move to the left (spend K permits), is equal to the area of
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 19.3K bytes - Viewed (0)