- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 1,074 for fclose (0.15 sec)
-
.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) -
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-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
Others - Registered: Tue May 07 12:40:20 GMT 2024 - Last Modified: Thu Nov 23 20:04:38 GMT 2023 - 4.1K bytes - Viewed (0) -
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 Apr 19 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 3.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* be transmitted before the close message is sent but subsequent calls to [send] will return * false and their messages will not be enqueued. * * This returns true if a graceful shutdown was initiated by this call. It returns false if * a graceful shutdown was already underway or if the web socket is already closed or canceled. * * @param code Status code as defined by
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.2K bytes - Viewed (2) -
guava-tests/test/com/google/common/io/TestOutputStream.java
public void close() throws IOException { closed = true; super.close(); throwIf(CLOSE_THROWS); } private void throwIf(TestOption option) throws IOException { throwIf(options.contains(option)); } private static void throwIf(boolean condition) throws IOException { if (condition) { throw new IOException(); } }
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.2K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
private val noContextTakeover: Boolean, ) : Closeable { private var closed = false // Stateful data about the current frame. private var opcode = 0 private var frameLength = 0L private var isFinalFrame = false private var isControlFrame = false private var readingCompressedMessage = false private val controlFrameBuffer = Buffer() private val messageFrameBuffer = Buffer()
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K 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) -
cmd/data-usage-cache.go
return hashPath(d.Info.Name) } // clone returns a copy of the cache with no references to the existing. func (d *dataUsageCache) clone() dataUsageCache { clone := dataUsageCache{ Info: d.Info, Cache: make(map[string]dataUsageEntry, len(d.Cache)), } for k, v := range d.Cache { clone.Cache[k] = v.clone() } return clone } // merge root of other into d.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1)