- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 1,027 for Closer (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
while (true) { if (closed) throw IOException("closed") if (frameLength > 0L) { source.readFully(messageFrameBuffer, frameLength) if (!isClient) { messageFrameBuffer.readAndWriteUnsafe(maskCursor!!) maskCursor.seek(messageFrameBuffer.size - frameLength) toggleMask(maskCursor, maskKey!!) maskCursor.close() } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.9K bytes - Viewed (0) -
mockwebserver-junit5/src/test/java/mockwebserver3/junit5/StartStopTest.kt
assertThat(dispatcherE.closed).isTrue() assertThat(dispatcherF.closed).isFalse() // Never started. } } } class ClosableDispatcher : Dispatcher() { var closed = false override fun dispatch(request: RecordedRequest) = MockResponse() override fun close() { closed = true } }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 11:13:17 UTC 2025 - 3.3K bytes - Viewed (0) -
src/test/java/jcifs/util/ResourceManagerTest.java
private final AtomicBoolean closed = new AtomicBoolean(false); private final String name; TestResource(String name) { this.name = name; } @Override public void close() { closed.set(true); } boolean isClosed() { return closed.get(); } String getName() {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 8.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/Exchange.kt
throw complete(e)!! } } @Throws(IOException::class) override fun close() { if (closed) return closed = true if (contentLength != -1L && bytesReceived != contentLength) { throw ProtocolException("unexpected end of stream") } try { super.close() complete(null) } catch (e: IOException) { throw complete(e)!! }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.7K bytes - Viewed (0) -
src/test/java/org/codelibs/core/io/CloseableUtilTest.java
CloseableUtil.close(out); } private static class NotifyOutputStream extends OutputStream { private String notify_; @Override public void write(final int arg0) throws IOException { } @Override public void close() throws IOException { super.close(); notify_ = "closed"; }
Registered: Fri Sep 05 20:58:11 UTC 2025 - Last Modified: Sat May 10 01:32:17 UTC 2025 - 2.2K bytes - Viewed (0) -
src/test/java/jcifs/smb/SmbPipeHandleImplTest.java
} @Test @DisplayName("ensureOpen throws after close() is called") void testEnsureOpenAfterClose() throws CIFSException { target.close(); CIFSException ex = assertThrows(SmbException.class, () -> target.ensureOpen()); assertTrue(ex.getMessage().contains("Pipe handle already closed")); } @Test
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 11.7K bytes - Viewed (0) -
src/archive/zip/writer_test.go
} continue } else { if !test.ok { t.Fatalf("SetComment: unexpected success, want error") } } if err := w.Close(); test.ok == (err != nil) { t.Fatal(err) } if w.closed != test.ok { t.Fatalf("Writer.closed: got %v, want %v", w.closed, test.ok) } // skip read test in failure cases if !test.ok { continue } // read it back
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Jan 28 04:20:09 UTC 2025 - 14.4K bytes - Viewed (0) -
.github/stale.yml
# Number of days of inactivity before an Issue or Pull Request becomes stale daysUntilStale: 30 # Number of days of inactivity before an Issue or Pull Request with the stale label is closed. # Set to false to disable. If disabled, issues still need to be closed manually, but will remain marked as stale. daysUntilClose: 15 # Only issues or pull requests with all of these labels are check if stale. Defaults to `[]` (disabled) onlyLabels: []
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Jan 24 04:36:59 UTC 2022 - 2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt
} @Throws(IOException::class) fun flush() { withLock { if (closed) throw IOException("closed") sink.flush() } } @Throws(IOException::class) fun rstStream( streamId: Int, errorCode: ErrorCode, ) { withLock { if (closed) throw IOException("closed") require(errorCode.httpCode != -1) frameHeader( streamId = streamId,
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11K bytes - Viewed (0) -
.github/workflows/stale.yml
permissions: contents: read jobs: stale: permissions: issues: write # for actions/stale to close stale issues pull-requests: write # for actions/stale to close stale PRs runs-on: ubuntu-latest env: ACTIONS_STEP_DEBUG: true steps: - name: Close Stale Issues uses: actions/stale@v8 with: repo-token: ${{ secrets.GITHUB_TOKEN }}
Registered: Sun Sep 07 09:35:13 UTC 2025 - Last Modified: Tue Apr 11 02:27:05 UTC 2023 - 972 bytes - Viewed (0)