- Sort Score
- Num 10 results
- Language All
Results 311 - 320 of 843 for closer (0.03 seconds)
-
build-logic/documentation/src/main/groovy/gradlebuild/docs/model/SimpleClassMetaDataRepository.java
ObjectOutputStream objOutputStream = new ObjectOutputStream(new BufferedOutputStream(outputStream)); objOutputStream.writeObject(classes); objOutputStream.close(); } finally { outputStream.close(); } } catch (IOException e) { throw new GradleException(String.format("Could not write meta-data to %s.", repoFile), e); } }
Created: Wed Dec 31 11:36:14 GMT 2025 - Last Modified: Wed May 21 06:20:45 GMT 2025 - 4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/FileBackedOutputStreamTest.java
.readAttributes(); assertThat(attributes.permissions()).containsExactly(OWNER_READ, OWNER_WRITE); } } out.close(); // Check that source returns the right data assertThat(source.read()).isEqualTo(data); // Make sure that reset deleted the file out.reset(); if (file != null) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Oct 30 16:30:29 GMT 2025 - 6.7K bytes - Click Count (0) -
src/archive/zip/zip_test.go
Method: Store, // Deflate is too slow when it is compiled with -race flag }) if err != nil { t.Fatalf("creating file %d: %v", i, err) } } if err := w.Close(); err != nil { t.Fatalf("Writer.Close: %v", err) } s := buf.String() zr, err := NewReader(strings.NewReader(s), int64(len(s))) if err != nil { t.Fatalf("NewReader: %v", err) } if got := len(zr.File); got != nFiles {Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Thu May 23 01:00:11 GMT 2024 - 19.6K bytes - Click Count (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 =
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Tue Nov 04 19:13:52 GMT 2025 - 25.8K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionReuseTest.kt
.url(server.url("/")) .header("Connection", "close") .build() val requestB = Request(server.url("/")) assertConnectionNotReused(requestA, requestB) } @Test fun connectionsAreNotReusedWithResponseConnectionClose() { server.enqueue( MockResponse( headers = headersOf("Connection", "close"), body = "a", ), )
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Jun 20 11:46:46 GMT 2025 - 12.2K bytes - Click Count (1) -
tests/test_stringified_annotation_dependency.py
if TYPE_CHECKING: # pragma: no cover from collections.abc import AsyncGenerator class DummyClient: async def get_people(self) -> list: return ["John Doe", "Jane Doe"] async def close(self) -> None: pass async def get_client() -> AsyncGenerator[DummyClient, None]: client = DummyClient() yield client await client.close()Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 21:25:59 GMT 2025 - 2.2K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Streams.java
return true; } return false; } }, isParallel) .onClose(streamA::close) .onClose(streamB::close); } /** * Invokes {@code consumer} once for each pair of <i>corresponding</i> elements in {@code streamA}Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 21 15:40:45 GMT 2025 - 36.8K bytes - Click Count (0) -
internal/deadlineconn/deadlineconn.go
c.infWrites.Store(t.IsZero()) c.writeSetAt = time.Time{} return c.Conn.SetWriteDeadline(t) } // Close wraps conn.Close and stops sending deadline updates. func (c *DeadlineConn) Close() error { c.abortReads.Store(true) c.abortWrites.Store(true) return c.Conn.Close() } // WithReadDeadline sets a new read side net.Conn deadline.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Dec 02 13:21:17 GMT 2024 - 5.1K bytes - Click Count (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/UploadProgress.kt
super.write(source, byteCount) totalBytesWritten += byteCount progressListener.update(totalBytesWritten, contentLength(), completed) } override fun close() { super.close() if (!completed) { completed = true progressListener.update(totalBytesWritten, contentLength(), completed) } } }
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Sat Aug 30 17:01:12 GMT 2025 - 3.8K bytes - Click Count (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()
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Sep 04 17:02:39 GMT 2024 - 3.2K bytes - Click Count (0)