- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 31 for closeable (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
android/guava-tests/test/com/google/common/io/CloserTest.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 11.8K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/CloserTest.java
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 16:03:47 GMT 2025 - 11.8K 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 Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Sep 11 13:51:27 GMT 2025 - 96.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/MessageInflater.kt
* limitations under the License. */ package okhttp3.internal.ws import java.io.Closeable import java.io.IOException import java.util.zip.Inflater import okio.Buffer import okio.InflaterSource private const val OCTETS_TO_ADD_BEFORE_INFLATION = 0x0000ffff class MessageInflater( private val noContextTakeover: Boolean, ) : Closeable { private val deflatedBytes = Buffer() // Lazily-created.
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sun Sep 21 06:26:07 GMT 2025 - 2.4K bytes - Click Count (0) -
src/main/java/org/codelibs/curl/CurlResponse.java
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: Sat Dec 20 09:13:53 GMT 2025 - Last Modified: Mon Nov 24 03:10:07 GMT 2025 - 7K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3 import java.io.Closeable import java.io.IOException import java.util.concurrent.LinkedBlockingDeque import okhttp3.internal.concurrent.TaskFaker import okhttp3.internal.connection.RealConnection import okhttp3.internal.connection.RoutePlanner
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Oct 07 21:55:03 GMT 2025 - 6.1K bytes - Click Count (0) -
CLAUDE.md
- **`org.codelibs.curl.CurlRequest`**: Fluent request builder supporting parameters, headers, body content, SSL config, proxies, timeouts, and caching - **`org.codelibs.curl.CurlResponse`**: Response wrapper implementing `Closeable` for proper resource management - **`org.codelibs.curl.CurlException`**: Unchecked exception for HTTP errors ### I/O Layer
Created: Sat Dec 20 09:13:53 GMT 2025 - Last Modified: Mon Nov 24 03:10:07 GMT 2025 - 3.2K bytes - Click Count (0) -
android/guava/src/com/google/common/io/CharSource.java
* despite the @IgnoreJRERequirement annotation there. For details, see ImmutableSortedMultiset. */ private static void closeUnchecked(Closeable closeable) { try { closeable.close(); } catch (IOException e) { throw new UncheckedIOException(e); } } /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 25.7K bytes - Click Count (0) -
guava/src/com/google/common/io/CharSource.java
* despite the @IgnoreJRERequirement annotation there. For details, see ImmutableSortedMultiset. */ private static void closeUnchecked(Closeable closeable) { try { closeable.close(); } catch (IOException e) { throw new UncheckedIOException(e); } } /**
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Sep 08 18:35:13 GMT 2025 - 25.3K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
* See the License for the specific language governing permissions and * limitations under the License. */ package okhttp3.internal.ws import java.io.Closeable import java.io.IOException import java.net.ProtocolException import java.util.concurrent.TimeUnit import okhttp3.internal.and import okhttp3.internal.closeQuietly import okhttp3.internal.toHexString
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 16:11:23 GMT 2025 - 10K bytes - Click Count (0)