- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 1,049 for closes (0.17 sec)
-
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
// Need successThreshold (2) consecutive successes to close the circuit // Second success should close the circuit (threshold is 2) result = circuitBreaker.executeWithCircuitBreaker(() -> "success 1"); assertEquals("success 1", result, "Should execute second success"); assertEquals(State.CLOSED, circuitBreaker.getState(), "Circuit should be CLOSED after success threshold");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.2K bytes - Viewed (0) -
src/main/java/jcifs/util/ResourceManager.java
public T get() { if (closed) { throw new IllegalStateException("Resource has been closed: " + resourceId); } return resource; } @Override public void close() throws Exception { if (closed) { return; } try { resource.close(); } finally {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 16.2K bytes - Viewed (0) -
.github/workflows/stale-issues.yml
It will be closed if no further activity occurs. Thank you. close-issue-message: > This issue was closed because it has been inactive for 7 days since being marked as stale. Please reopen if you'd like to work on this further. days-before-pr-stale: 14 days-before-pr-close: 14
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Sat Feb 01 08:42:17 UTC 2025 - 4.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyTest.kt
override fun close() { closed = true super.close() } }.buffer() } } body.source().close() assertThat(closed).isTrue() } @Test fun throwingUnderlyingSourceClosesQuietly() { val body: ResponseBody = object : ResponseBody() { override fun contentType(): MediaType? = null
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 3.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ResponseBodyJvmTest.kt
@Throws(IOException::class) override fun close() { closed.set(true) super.close() } }.buffer() } } body.charStream().close() assertThat(closed.get()).isTrue() } @Test fun readerClosedAfterBomClosesUnderlyingSource() { val closed = AtomicBoolean() val body: ResponseBody =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 12.4K bytes - Viewed (0) -
android/guava/src/com/google/common/io/AppendableWriter.java
checkNotClosed(); if (target instanceof Flushable) { ((Flushable) target).flush(); } } @Override public void close() throws IOException { this.closed = true; if (target instanceof Closeable) { ((Closeable) target).close(); } } @Override public Writer append(char c) throws IOException { checkNotClosed(); target.append(c); return this;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:37:28 UTC 2025 - 3.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 02:11:14 UTC 2025 - 7.3K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/CopyUtil.java
} finally { CloseableUtil.close(os); } } // //////////////////////////////////////////////////////////////// // from InputStream to StringBuilder // /** * Copies from an input stream to a {@link StringBuilder} using the platform default encoding. * <p> * The input stream is not closed. * </p> *
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Thu Jul 31 08:16:49 UTC 2025 - 45.2K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.8.md
Don't use these flags. Using deprecated flags causes the server to print a warning. Using a removed flag causes the server to abort the startup. * The following deprecated flags were removed from `kubelet`: * `api-servers` - add apiserver addresses to the kubeconfig file instead. Don't use these flags. Using deprecated flags causes the kubelet to print a warning. Using a removed flag causes the kubelet to abort the startup.
Registered: Fri Sep 05 09:05:11 UTC 2025 - Last Modified: Tue Feb 20 15:45:02 UTC 2024 - 312.2K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbPipeInputStreamTest.java
}).when(tree).send(any(TransPeekNamedPipe.class), any(TransPeekNamedPipeResponse.class), eq(RequestParam.NO_RETRY)); int available = stream.available(); assertEquals(0, available, "Disconnected/server-closed should yield 0 available"); verify(fd, times(1)).markClosed(); verify(tree, times(1)).close(); verify(fd, times(1)).close(); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 9.9K bytes - Viewed (0)