- Sort Score
- Num 10 results
- Language All
Results 321 - 330 of 817 for closer (0.03 seconds)
-
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/config/identity/ldap/ldap.go
// username. func (l *Config) LookupUserDN(username string) (*xldap.DNSearchResult, []string, error) { conn, err := l.LDAP.Connect() if err != nil { return nil, nil, err } defer conn.Close() // Bind to the lookup user account if err = l.LDAP.LookupBind(conn); err != nil { return nil, nil, err } // Lookup user DN lookupRes, err := l.LDAP.LookupUsername(conn, username) if err != nil {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jul 12 01:04:53 GMT 2024 - 12.4K bytes - Click Count (1) -
okhttp/src/jvmTest/kotlin/okhttp3/HeadersTest.kt
} } @Test fun headersEquals() { val headers1 = Headers .Builder() .add("Connection", "close") .add("Transfer-Encoding", "chunked") .build() val headers2 = Headers .Builder() .add("Connection", "close") .add("Transfer-Encoding", "chunked") .build() assertThat(headers2).isEqualTo(headers1)
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed Mar 19 19:25:20 GMT 2025 - 8.7K bytes - Click Count (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];
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Thu Dec 19 18:03:30 GMT 2024 - 3.2K bytes - Click Count (0) -
internal/s3select/simdj/reader_amd64_test.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 3.9K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/io/TestByteSource.java
private final class In extends TestInputStream { In() throws IOException { super(new ByteArrayInputStream(bytes), options); } @Override public void close() throws IOException { inputStreamClosed = true; super.close(); } }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 2K bytes - Click Count (0) -
guava-tests/test/com/google/common/io/TestByteSource.java
private final class In extends TestInputStream { In() throws IOException { super(new ByteArrayInputStream(bytes), options); } @Override public void close() throws IOException { inputStreamClosed = true; super.close(); } }Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Mon Jul 14 14:44:08 GMT 2025 - 2K bytes - Click Count (0) -
fastapi/datastructures.py
""" return await super().seek(offset) async def close(self) -> None: """ Close the file. To be awaitable, compatible with async, this is run in threadpool. """ return await super().close() @classmethod def _validate(cls, __input_value: Any, _: Any) -> "UploadFile":Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Dec 27 12:54:56 GMT 2025 - 5.1K bytes - Click Count (0) -
internal/http/listener_test.go
for _, serverAddr := range listener.Addrs() { conn, err := net.Dial("tcp", serverAddr.String()) if err != nil { t.Fatalf("Test %d: error: expected = <nil>, got = %v", i+1, err) } conn.Close() } listener.Close() } } func TestHTTPListenerAddr(t *testing.T) { if runtime.GOOS == "windows" { t.Skip() } nonLoopBackIP := getNonLoopBackIP(t) var casePorts []string
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 11.8K bytes - Click Count (0) -
internal/store/batch_test.go
Limit: limit, Store: store, CommitTimeout: 5 * time.Minute, Log: func(ctx context.Context, err error, id string, errKind ...any) { t.Log(err) }, }) defer batch.Close() for i := 0; i < int(limit); i++ { if err := batch.Add(testItem); err != nil { t.Fatalf("failed to add %v; %v", i, err) } } batchLen := batch.Len() if batchLen != int(limit) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 5.6K bytes - Click Count (0)