- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 433 for close (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) -
android/guava/src/com/google/common/io/Closeables.java
* IOException}. */ public static void close(@CheckForNull Closeable closeable, boolean swallowIOException) throws IOException { if (closeable == null) { return; } try { closeable.close(); } catch (IOException e) { if (swallowIOException) { logger.log(Level.WARNING, "IOException thrown while closing Closeable.", e); } else { throw e;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 4.7K bytes - Viewed (0) -
internal/logger/logrotate.go
return err } defer gw.Close() var wc io.WriteCloser wc = gzip.NewWriter(gw) if _, err = io.Copy(wc, r); err != nil { return err } if err = wc.Close(); err != nil { return err } // Persist to disk any caches. if err = gw.Sync(); err != nil { return err } // close everything before we delete. if err = gw.Close(); err != nil { return err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu May 02 11:38:40 GMT 2024 - 5.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test fun racingReaders() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
internal/s3select/simdj/reader.go
if !ok { dstRec = &Record{} } dstRec.object = v return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. // Potentially racy if the stream decoder is still reading. if r.readCloser != nil { r.readCloser.Close() } if r.exitReader != nil { close(r.exitReader) r.readerWg.Wait() r.exitReader = nil r.input = nil } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K 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) -
.github/workflows/stale-pr.yml
It will be closed in 14 days if no further activity occurs. If you don't want the stale bot to close it, then set a milestone for it. days-before-pr-close: 14 close-pr-message: >
Others - Registered: Wed May 08 11:36:15 GMT 2024 - Last Modified: Thu May 02 09:13:16 GMT 2024 - 1.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/AppendableWriterTest.java
writer.write("Hi"); writer.close(); assertThrows(IOException.class, () -> writer.write(" Greg")); assertThrows(IOException.class, () -> writer.flush()); // close()ing already closed writer is allowed writer.close(); }
Java - Registered: Fri May 03 12:43:13 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.2K bytes - Viewed (0) -
internal/http/listener.go
} case <-listener.ctx.Done(): } return nil, syscall.EINVAL } // Close - closes underneath all TCP listeners. func (listener *httpListener) Close() (err error) { listener.ctxCanceler() for i := range listener.listeners { listener.listeners[i].Close() } return nil }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K 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"; }
Java - Registered: Fri May 03 20:58:11 GMT 2024 - Last Modified: Thu Mar 07 01:59:08 GMT 2024 - 2.2K bytes - Viewed (0)