- Sort Score
- Result 10 results
- Languages All
Results 221 - 230 of 887 for closure (0.07 sec)
-
internal/ringbuffer/README.md
`TryRead` and `TryWrite` are still available for non-blocking reads and writes. To signify the end of the stream, close the ring buffer from the writer side with `rb.CloseWriter()` Either side can use `rb.CloseWithError(err error)` to signal an error and close the ring buffer. Any reads or writes will return the error on next call.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed May 15 00:11:04 UTC 2024 - 2.1K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/kotlin/gradlebuild/binarycompatibility/BinaryCompatibilityRepository.kt
BinaryCompatibilityRepository(SourcesRepository(sourceRoots, compilationClasspath)) } @VisibleForTesting fun emptyCaches() = sources.close() override fun close() = emptyCaches() fun isOverride(method: JApiMethod): Boolean = apiSourceFileFor(method).let { apiSourceFile -> when (apiSourceFile) {
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Fri Jun 28 08:29:28 UTC 2024 - 3.7K bytes - Viewed (0) -
internal/event/target/nats_tls_contrib_test.go
CertAuthority: path.Join("testdata", "contrib", "certs", "root_ca_cert.pem"), } con, err := clientConfig.connectNats() if err != nil { t.Errorf("Could not connect to nats: %v", err) } defer con.Close() } func TestNatsConnTLSClientAuthorization(t *testing.T) { s, opts := natsserver.RunServerWithConfig(filepath.Join("testdata", "contrib", "nats_tls_client_cert.conf")) defer s.Shutdown()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.1K bytes - Viewed (0) -
src/cmd/buildid/buildid.go
return } // Keep in sync with src/cmd/go/internal/work/buildid.go:updateBuildID f, err := os.Open(file) if err != nil { log.Fatal(err) } matches, hash, err := buildid.FindAndHash(f, id, 0) f.Close() if err != nil { log.Fatal(err) } // <= go 1.7 doesn't embed the contentID or actionID, so no slash is present if !strings.Contains(id, "/") {
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Fri Jun 21 19:58:04 UTC 2024 - 1.7K bytes - Viewed (0) -
cmd/lock-rest-client.go
func (c *lockRESTClient) IsOnline() bool { return c.connection.State() == grid.StateConnected } // Not a local locker func (c *lockRESTClient) IsLocal() bool { return false } // Close - marks the client as closed. func (c *lockRESTClient) Close() error { return nil } // String - returns the remote host of the connection. func (c *lockRESTClient) String() string { return c.connection.Remote }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 3.3K bytes - Viewed (0) -
internal/grid/grid_test.go
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 36.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/TestByteSource.java
public In() throws IOException { super(new ByteArrayInputStream(bytes), options); } @Override public void close() throws IOException { inputStreamClosed = true; super.close(); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Apr 21 02:27:51 UTC 2017 - 1.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/TestByteSource.java
public In() throws IOException { super(new ByteArrayInputStream(bytes), options); } @Override public void close() throws IOException { inputStreamClosed = true; super.close(); } }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Sep 15 13:47:32 UTC 2016 - 1.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/MessageDeflaterInflaterTest.kt
} @Test fun `deflate after close`() { val deflater = MessageDeflater(true) deflater.close() assertFailsWith<Exception> { deflater.deflate("Hello deflate!".encodeUtf8()) } } @Test fun `inflate after close`() { val inflater = MessageInflater(false) inflater.close() assertFailsWith<Exception> {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 06 05:31:00 UTC 2024 - 5K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/io/TestOutputStream.java
} @Override public void write(int b) throws IOException { throwIf(closed); throwIf(WRITE_THROWS); super.write(b); } @Override public void close() throws IOException { closed = true; super.close(); throwIf(CLOSE_THROWS); } private void throwIf(TestOption option) throws IOException { throwIf(options.contains(option)); }
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Dec 04 17:37:03 UTC 2017 - 2.2K bytes - Viewed (0)