- Sort Score
- Result 10 results
- Languages All
Results 391 - 400 of 1,049 for closes (0.03 sec)
-
samples/guide/src/main/java/okhttp3/recipes/kt/UploadProgress.kt
} } private class ProgressRequestBody( private val delegate: RequestBody, private val progressListener: ProgressListener, ) : RequestBody() { override fun contentType() = delegate.contentType() @Throws(IOException::class) override fun contentLength(): Long = delegate.contentLength() @Throws(IOException::class) override fun writeTo(sink: BufferedSink) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 17:01:12 UTC 2025 - 3.8K bytes - Viewed (0) -
cmd/signals.go
finished := make(chan struct{}) go func() { globalMRFState.shutdown() close(finished) }() select { case <-time.After(shutdownTimeout): case <-finished: } } func handleSignals() { // Custom exit function exit := func(success bool) { if globalLoggerOutput != nil { globalLoggerOutput.Close() } // If global profiler is set stop before we exit. globalProfilerMu.Lock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Sep 04 17:02:39 UTC 2024 - 3.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketRecorder.kt
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 6.8K bytes - Viewed (0) -
src/cmd/asm/internal/lex/stack.go
func (s *Stack) Push(tr TokenReader) { s.tr = append(s.tr, tr) } func (s *Stack) Next() ScanToken { tos := s.tr[len(s.tr)-1] tok := tos.Next() for tok == scanner.EOF && len(s.tr) > 1 { tos.Close() // Pop the topmost item from the stack and resume with the next one down. s.tr = s.tr[:len(s.tr)-1] tok = s.Next() } return tok } func (s *Stack) Text() string { return s.tr[len(s.tr)-1].Text()
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Mon Jan 09 22:33:23 UTC 2017 - 1.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/CharSourceTester.java
StringWriter writer = new StringWriter(); char[] buf = new char[64]; int read; while ((read = reader.read(buf)) != -1) { writer.write(buf, 0, read); } reader.close(); writer.close(); assertExpectedString(writer.toString()); } public void testOpenBufferedStream() throws IOException { BufferedReader reader = source.openBufferedStream();
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 6.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/contents/querylog/QueryLogReader.java
* It extends the {@code Closeable} interface, ensuring that resources can be released when no longer needed. */ public interface QueryLogReader extends Closeable { /** * Reads a query log. * @return The query log. */ QueryLog read(); @Override void close();
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 1.1K bytes - Viewed (0) -
guava-tests/benchmark/com/google/common/io/BaseEncodingBenchmark.java
StringWriter target = new StringWriter(2 * n); OutputStream encodingStream = encoding.encoding.encodingStream(target); encodingStream.write(encodingInputs[i & INPUTS_MASK]); encodingStream.close(); tmp += target.getBuffer().length(); } return tmp; } @Benchmark public int decodingStream(int reps) throws IOException { int tmp = 0; byte[] target = new byte[n];
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Dec 19 18:03:30 UTC 2024 - 3.2K bytes - Viewed (0) -
src/main/webapp/js/bootstrap.min.js.map
*/\n\nconst NAME = 'alert'\nconst DATA_KEY = 'bs.alert'\nconst EVENT_KEY = `.${DATA_KEY}`\n\nconst EVENT_CLOSE = `close${EVENT_KEY}`\nconst EVENT_CLOSED = `closed${EVENT_KEY}`\nconst CLASS_NAME_FADE = 'fade'\nconst CLASS_NAME_SHOW = 'show'\n\n/**\n * Class definition\n */\n\nclass Alert extends BaseComponent {\n // Getters\n static get NAME() {\n return NAME\n }\n\n // Public\n close() {\n const closeEvent = EventHandler.trigger(this._element, EVENT_CLOSE)\n\n if (closeEvent.defaultPrevented)...
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Jan 12 06:14:02 UTC 2025 - 211.9K bytes - Viewed (0) -
src/main/java/jcifs/SmbSession.java
* * @author mbechler */ public interface SmbSession extends AutoCloseable { /** * {@inheritDoc} * * @see java.lang.AutoCloseable#close() */ @Override void close(); /** * Returns the configuration object used by this SMB session. * * @return the configuration used by this session */ Configuration getConfig();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 1.7K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/DuplexTest.kt
.isEqualTo("response D") requestBody.writeUtf8("request E\n") requestBody.flush() assertThat(responseBody.readUtf8Line()) .isEqualTo("response F") requestBody.close() assertThat(responseBody.readUtf8Line()).isNull() } body.awaitSuccess() } @Test fun trueDuplexServerWritesFirst() { enableProtocol(Protocol.HTTP_2) val body =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 24.8K bytes - Viewed (0)