- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 551 for ensures (0.05 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
public void testSubmit() throws Exception { /* * Mostly just tests that TrustedListenableFutureTask are created and run; tests for * TrustedListenableFutureTask should ensure that listeners are called correctly. */ TestListeningExecutorService e = new TestListeningExecutorService(); TestRunnable runnable = new TestRunnable();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractListeningExecutorServiceTest.java
public void testSubmit() throws Exception { /* * Mostly just tests that TrustedListenableFutureTask are created and run; tests for * TrustedListenableFutureTask should ensure that listeners are called correctly. */ TestListeningExecutorService e = new TestListeningExecutorService(); TestRunnable runnable = new TestRunnable();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 3.2K bytes - Viewed (0) -
docs/en/docs/css/termynal.css
a[data-terminal-control] { text-align: right; display: block; color: #aebbff; } [data-ty] { display: block; line-height: 2; } [data-ty]:before { /* Set up defaults and ensure empty lines are displayed. */ content: ''; display: inline-block; vertical-align: middle; } [data-ty="input"]:before, [data-ty-prompt]:before { margin-right: 0.75em;
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Aug 09 01:42:26 UTC 2024 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/SingletonImmutableSet.java
@SuppressWarnings("serial") // uses writeReplace(), not default serialization @ElementTypesAreNonnullByDefault final class SingletonImmutableSet<E> extends ImmutableSet<E> { // We deliberately avoid caching the asList and hashCode here, to ensure that with // compressed oops, a SingletonImmutableSet packs all the way down to the optimal 16 bytes. final transient E element; SingletonImmutableSet(E element) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 30 16:15:19 UTC 2024 - 2.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* } * }, * MoreExecutors.directExecutor()); * * Runtime.getRuntime().addShutdownHook(new Thread() { * public void run() { * // Give the services 5 seconds to stop to ensure that we are responsive to shutdown * // requests. * try { * manager.stopAsync().awaitStopped(5, TimeUnit.SECONDS); * } catch (TimeoutException timeout) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.5K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ServiceManager.java
* } * }, * MoreExecutors.directExecutor()); * * Runtime.getRuntime().addShutdownHook(new Thread() { * public void run() { * // Give the services 5 seconds to stop to ensure that we are responsive to shutdown * // requests. * try { * manager.stopAsync().awaitStopped(5, TimeUnit.SECONDS); * } catch (TimeoutException timeout) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 33.2K bytes - Viewed (0) -
api/maven-api-cli/src/main/java/org/apache/maven/api/cli/Invoker.java
* * <p>The Invoker is designed to be flexible, allowing for different implementations * that can handle various types of {@link InvokerRequest InvokerRequests}. It also implements * {@link AutoCloseable} to ensure proper resource management.</p> * * @param <R> The specific type of {@link InvokerRequest} this {@code Invoker} can handle, extending {@link InvokerRequest} * * @since 4.0.0 */ @Experimental
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Oct 03 16:03:55 UTC 2024 - 2.7K bytes - Viewed (0) -
guava-testlib/README.md
used on the CLASSPATH of users outside your own control), you should not use beta APIs, unless you [repackage] them. **If your code is a library, we strongly recommend using the [Guava Beta Checker] to ensure that you do not use any `@Beta` APIs!** [Guava Beta Checker]: https://github.com/google/guava-beta-checker <!-- References -->
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Tue Sep 24 18:34:38 UTC 2024 - 1.7K bytes - Viewed (0) -
internal/ioutil/hardlimitreader.go
// but returns an error if the source provides more data than allowed. // This means the source *will* be overread unless EOF is returned prior. // The underlying implementation is a *HardLimitedReader. // This will ensure that at most n bytes are returned and EOF is reached. func HardLimitReader(r io.Reader, n int64) io.Reader { return &HardLimitedReader{r, n} } // A HardLimitedReader reads from R but limits the amount of
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sat May 06 02:53:12 UTC 2023 - 2K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
part.Number, NewPutObjReader(hr), ObjectOptions{ PreserveETag: part.ETag, // Preserve original ETag to ensure same metadata. IndexCB: func() []byte { return part.Index // Preserve part Index to ensure decompression works. }, NoAuditLog: true, }) if err != nil { return fmt.Errorf("rebalanceObject: PutObjectPart() %w", err) }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 28.4K bytes - Viewed (0)