- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 13 for closeIdle (0.33 seconds)
-
guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java
ClosingFuture<Closeable> closingFuture = ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor); FluentFuture<Closeable> unused = closingFuture.finishToFuture(); assertThrows( IllegalStateException.class, () -> { FluentFuture<Closeable> unused2 = closingFuture.finishToFuture(); }); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 3.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToFutureTest.java
ClosingFuture<Closeable> closingFuture = ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor); FluentFuture<Closeable> unused = closingFuture.finishToFuture(); assertThrows( IllegalStateException.class, () -> { FluentFuture<Closeable> unused2 = closingFuture.finishToFuture(); }); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 3.3K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java
} public void testFinishToValueAndCloser_throwsAfterCallingFinishToFuture() throws Exception { ClosingFuture<Closeable> closingFuture = ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor); FluentFuture<Closeable> unused = closingFuture.finishToFuture(); assertThrows( IllegalStateException.class, () ->
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 5.2K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/ClosingFutureFinishToValueAndCloserTest.java
} public void testFinishToValueAndCloser_throwsAfterCallingFinishToFuture() throws Exception { ClosingFuture<Closeable> closingFuture = ClosingFuture.submit(closer -> closer.eventuallyClose(mockCloseable, executor), executor); FluentFuture<Closeable> unused = closingFuture.finishToFuture(); assertThrows( IllegalStateException.class, () ->
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 5.2K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
throws IOException { for (TestCloseable closeable : asList(closeable1, moreCloseables)) { assertWithMessage("%s.stillOpen()", closeable).that(closeable.stillOpen()).isTrue(); } } static void assertClosed(TestCloseable closeable1, TestCloseable... moreCloseables) throws IOException { for (TestCloseable closeable : asList(closeable1, moreCloseables)) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
throws IOException { for (TestCloseable closeable : asList(closeable1, moreCloseables)) { assertWithMessage("%s.stillOpen()", closeable).that(closeable.stillOpen()).isTrue(); } } static void assertClosed(TestCloseable closeable1, TestCloseable... moreCloseables) throws IOException { for (TestCloseable closeable : asList(closeable1, moreCloseables)) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 63K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
} } void add(@Nullable AutoCloseable closeable, Executor executor) { checkNotNull(executor); if (closeable == null) { return; } synchronized (this) { if (!closed) { put(closeable, executor); return; } } closeQuietly(closeable, executor); } /**Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 101.7K bytes - Click Count (0) -
src/main/java/org/codelibs/curl/io/ContentCache.java
import java.io.ByteArrayInputStream; import java.io.Closeable; import java.io.File; import java.io.FileInputStream; import java.io.IOException; import java.io.InputStream; import java.nio.file.Files; import java.util.logging.Logger; /** * ContentCache is a class that provides a way to cache content either in memory or in a file. * It implements the Closeable interface to ensure that resources are properly released. *
Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 09:11:12 GMT 2026 - 4.8K bytes - Click Count (0) -
src/main/java/org/codelibs/curl/CurlResponse.java
package org.codelibs.curl; import java.io.Closeable; import java.io.IOException; import java.io.InputStream; import java.util.HashMap; import java.util.List; import java.util.Locale; import java.util.Map; import java.util.function.Function; import org.codelibs.curl.io.ContentCache; /** * The CurlResponse class represents the response from a cURL request. * It implements the Closeable interface to allow proper resource management.
Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 09:11:12 GMT 2026 - 6.8K bytes - Click Count (0) -
android/guava/src/com/google/common/base/FinalizableReferenceQueue.java
import com.google.common.annotations.GwtIncompatible; import com.google.common.annotations.J2ktIncompatible; import com.google.common.annotations.VisibleForTesting; import com.google.common.base.internal.Finalizer; import java.io.Closeable; import java.io.FileNotFoundException; import java.io.IOException; import java.lang.ref.PhantomReference; import java.lang.ref.Reference; import java.lang.ref.ReferenceQueue; import java.lang.reflect.Method;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 19:26:59 GMT 2026 - 15.8K bytes - Click Count (0)