- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,327 for closed (0.34 sec)
-
internal/http/close.go
) // 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. // If resp.Body is not closed, the Client's underlying RoundTripper
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) -
.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: []
Others - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Jan 24 04:36:59 GMT 2022 - 2K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
} } // Avoid infinite recursion if a closeable's close() method throws RejectedExecutionException and // is closed using the direct executor. public void testCloseThrowsRejectedExecutionException() throws Exception { doThrow(new RejectedExecutionException()).when(mockCloseable).close(); ClosingFuture<Closeable> closingFuture = ClosingFuture.submit(
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Thu Feb 22 17:15:24 GMT 2024 - 75.3K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/BoundType.java
* ("open"). If a range is unbounded on a side, it is neither open nor closed on that side; the * bound simply does not exist. * * @since 10.0 */ @GwtCompatible @ElementTypesAreNonnullByDefault public enum BoundType { /** The endpoint value <i>is not</i> considered part of the set ("exclusive"). */ OPEN(false), CLOSED(true); final boolean inclusive;
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Sep 20 15:57:47 GMT 2021 - 1.4K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
) { get().log("[ES] onEvent", Platform.INFO, null) events.add(Event(id, type, data)) drainCancelQueue(eventSource) } override fun onClosed(eventSource: EventSource) { get().log("[ES] onClosed", Platform.INFO, null) events.add(Closed) drainCancelQueue(eventSource) } override fun onFailure( eventSource: EventSource, t: Throwable?, response: Response?, ) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.1K 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) -
android/guava-tests/test/com/google/common/io/TestStreamSupplier.java
* stream was closed. Intended for use in a test where only a single stream should be opened and * possibly closed. * * @author Colin Decker */ public interface TestStreamSupplier { /** Returns whether or not a new stream was opened. */ boolean wasStreamOpened(); /** Returns whether or not an open stream was closed. */ boolean wasStreamClosed();
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 1.1K 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/CloseablesTest.java
new TestInputStream(new ByteArrayInputStream(new byte[1]), TestOption.CLOSE_THROWS); Closeables.closeQuietly(in); assertTrue(in.closed()); } public void testCloseQuietly_readerWithEatenException() throws IOException { TestReader in = new TestReader(TestOption.CLOSE_THROWS); Closeables.closeQuietly(in); assertTrue(in.closed()); } public void testCloseNull() throws IOException {
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 4K bytes - Viewed (0) -
internal/grid/muxclient.go
} } // send the message. msg.Seq and msg.MuxID will be set func (m *muxClient) send(msg message) error { m.respMu.Lock() defer m.respMu.Unlock() if m.closed { return errors.New("mux client closed") } return m.sendLocked(msg) } // sendLocked the message. msg.Seq and msg.MuxID will be set. // m.respMu must be held. func (m *muxClient) sendLocked(msg message) error {
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 14.2K bytes - Viewed (0)