- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 641 for Close (0.16 sec)
-
internal/http/close.go
"io" xioutil "github.com/minio/minio/internal/ioutil" ) // DrainBody close non nil response with any response Body. // convenient wrapper to drain any remaining data on response body. // // Subsequently this allows golang http RoundTripper // to reuse the same connection for future requests. func DrainBody(respBody io.ReadCloser) { // Callers should close resp.Body when done reading from it.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 1.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/RealWebSocketTest.kt
server.listener.assertExhausted() server.source.close() client.source.close() taskFaker.runTasks() server.webSocket!!.tearDown() client.webSocket!!.tearDown() taskFaker.close() } @Test fun close() { client.webSocket!!.close(1000, "Hello!") // This will trigger a close response. assertThat(server.processNextFrame()).isFalse()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 01:59:58 GMT 2024 - 18.5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CharSourceTest.java
static final CharSource BROKEN_CLOSE_SOURCE = new TestCharSource("ABC", CLOSE_THROWS); static final CharSource BROKEN_OPEN_SOURCE = new TestCharSource("ABC", OPEN_THROWS); static final CharSink BROKEN_WRITE_SINK = new TestCharSink(WRITE_THROWS); static final CharSink BROKEN_CLOSE_SINK = new TestCharSink(CLOSE_THROWS); static final CharSink BROKEN_OPEN_SINK = new TestCharSink(OPEN_THROWS);
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 12K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CloserTest.java
TestCloseable c3 = closer.register(TestCloseable.normal()); assertFalse(c1.isClosed()); assertFalse(c2.isClosed()); assertFalse(c3.isClosed()); closer.close(); assertTrue(c1.isClosed()); assertTrue(c2.isClosed()); assertTrue(c3.isClosed()); assertTrue(suppressor.suppressions.isEmpty()); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Mar 06 15:15:46 GMT 2024 - 13.6K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseBodyTest.kt
val source = Buffer().writeUtf8("hello") return object : ForwardingSource(source) { override fun close() { closed = true super.close() } }.buffer() } } body.source().close() assertThat(closed).isTrue() } @Test fun throwingUnderlyingSourceClosesQuietly() { val body: ResponseBody =
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/RealWebSocket.kt
synchronized(this) { queueSize -= message.data.size.toLong() } } else if (messageOrClose is Close) { val close = messageOrClose as Close writer!!.writeClose(close.code, close.reason) // We closed the writer: now both reader and writer are closed. if (streamsToClose != null) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Apr 01 14:21:25 GMT 2024 - 22.1K bytes - Viewed (0) -
internal/s3select/csv/reader.go
dstRec.nameIndexMap = r.nameIndexMap return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { if r.close != nil { close(r.close) r.readerWg.Wait() r.close = nil } r.recordsRead = len(r.current) if r.err == nil { r.err = io.EOF } return r.readCloser.Close() } // nextSplit will attempt to skip a number of bytes and
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 8.9K bytes - Viewed (0) -
android/guava/src/com/google/common/io/CountingOutputStream.java
out.write(b); count++; } // Overriding close() because FilterOutputStream's close() method pre-JDK8 has bad behavior: // it silently ignores any exception thrown by flush(). Instead, just close the delegate stream. // It should flush itself if necessary. @Override public void close() throws IOException { out.close(); }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 28 20:13:02 GMT 2023 - 2K 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 }}
Others - Registered: Sun May 05 09:35:13 GMT 2024 - Last Modified: Tue Apr 11 02:27:05 GMT 2023 - 972 bytes - Viewed (0) -
.github/workflows/stale-pr.yml
Please report it to @gradle/bt-support team days-before-issue-close: -1 close-issue-message: > **BUG!** This issue should not be closed by the "stale" workflow. Please report it to @gradle/bt-support team close-issue-reason: not_planned # PULL REQUESTS -----------------------------------------------------
Others - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Mon Feb 05 12:52:42 GMT 2024 - 1.7K bytes - Viewed (0)