- Sort Score
- Num 10 results
- Language All
Results 821 - 830 of 1,301 for Closer (0.06 seconds)
-
doc/README.md
unfinished release note work. To prepare the release notes for a release, run `relnote generate`. That will merge the `.md` files in `next` into a single file. Atomically (as close to it as possible) add that file to `_content/doc` directory of the website repository and remove the `doc/next` directory in this repository. To begin the next release development cycle, populate the contents of `next`
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Mon Jul 22 17:55:04 GMT 2024 - 3.1K bytes - Click Count (0) -
src/test/java/org/codelibs/curl/CurlResponseTest.java
response.setContentCache(cache); // Should not throw exception response.close(); } @Test public void testCloseWithoutContentCache() throws IOException { CurlResponse response = new CurlResponse(); // Should not throw exception response.close(); } @Test public void testHeadersCaseInsensitive() {
Created: Thu Apr 02 15:34:12 GMT 2026 - Last Modified: Sat Mar 21 09:11:12 GMT 2026 - 17.7K bytes - Click Count (0) -
build-logic/documentation/src/main/groovy/gradlebuild/docs/XslTransformer.java
} FileOutputStream outstr = new FileOutputStream(dest); try { transformer.transform(new StreamSource(source), new StreamResult(outstr)); } finally { outstr.close(); } }Created: Wed Apr 01 11:36:16 GMT 2026 - Last Modified: Thu Oct 05 19:36:14 GMT 2023 - 2.2K bytes - Click Count (0) -
samples/compare/src/test/kotlin/okhttp3/compare/ApacheHttpClientTest.kt
*/ class ApacheHttpClientTest { private val httpClient = HttpClients.createDefault() @StartStop private val server = MockWebServer() @AfterEach fun tearDown() { httpClient.close() } @Test fun get() { server.enqueue( MockResponse .Builder() .body("hello, Apache HttpClient 5.x") .build(), )Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Feb 04 20:23:14 GMT 2026 - 2.3K bytes - Click Count (0) -
src/cmd/asm/internal/lex/slice.go
// The first definition of B has an argument, the second doesn't. Because we let // text/scanner strip the blanks for us, this is extremely rare, hard to fix, and not worth it. return s.pos } func (s *Slice) Close() {
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Thu Jun 29 22:49:50 GMT 2023 - 1.6K bytes - Click Count (0) -
internal/s3select/select_test.go
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 76.1K bytes - Click Count (0) -
doc/go_mem.html
the <code>print</code>. </p> <p class="rule"> The closing of a channel is synchronized before a receive that returns a zero value because the channel is closed. </p> <p> In the previous example, replacing <code>c <- 0</code> with <code>close(c)</code> yields a program with the same guaranteed behavior. </p> <p class="rule"> A receive from an unbuffered channel is synchronized before the completion of
Created: Tue Apr 07 11:13:11 GMT 2026 - Last Modified: Tue Aug 05 15:41:37 GMT 2025 - 26.6K bytes - Click Count (0) -
docs/es/docs/tutorial/dependencies/dependencies-with-yield.md
operation ->> dep_func: Return from path operation Note over dep_func: Run code after yield Note over dep_func: ✅ Dependency closed dep_func ->> client: Send response to client Note over client: Response sent Note over dep_req: Run code after yield Note over dep_req: ✅ Dependency closed ```Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 19 18:15:55 GMT 2026 - 13.3K bytes - Click Count (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/duplex/MockSocketHandler.kt
actions += { stream -> stream.sink.writeUtf8(s) stream.sink.flush() responseSent.countDown() } } fun exhaustResponse() = apply { actions += { stream -> stream.sink.close() } } fun sleep( duration: Long, unit: TimeUnit, ) = apply { actions += { Thread.sleep(unit.toMillis(duration)) } } override fun handle(socket: Socket) {Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 3.3K bytes - Click Count (0) -
internal/s3select/jstream/scanner.go
fillReq: make(chan struct{}), fillReady: make(chan int64), } go func() { var rpos int64 // total bytes read into buffer defer func() { atomic.StoreInt64(&sr.end, rpos) close(sr.fillReady) }() for range sr.fillReq { scan: n, err := r.Read(sr.nbuf[:]) if n == 0 { switch err { case io.EOF: // reader is exhausted return
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Mon Sep 23 19:35:41 GMT 2024 - 2.5K bytes - Click Count (0)