- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 92 for closeFn (0.15 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java
new ClosingCallable<TestCloseable>() { @Override public TestCloseable call(DeferredCloser closer) throws Exception { closer.eventuallyClose(closeable1, closingExecutor); closer.eventuallyClose(closeable2, closingExecutor); return closeable3; } }, executor)
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue May 07 12:37:15 UTC 2024 - 75.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
wg.Add(1) handler := func(w http.ResponseWriter, r *http.Request) { ctx := r.Context() // asynchronously wait for context being closed go func() { <-ctx.Done() wg.Done() }() } server := httptest.NewServer(http.HandlerFunc(handler)) defer server.Close() if err := expectHTTPGet(fmt.Sprintf("%s/api/v1/namespaces/default/pods?watch=true", server.URL), http.StatusOK); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
src/crypto/tls/tls_test.go
func TestDialer(t *testing.T) { ln := newLocalListener(t) defer ln.Close() unblockServer := make(chan struct{}) // close-only defer close(unblockServer) go func() { conn, err := ln.Accept() if err != nil { return } defer conn.Close() <-unblockServer }() ctx, cancel := context.WithCancel(context.Background())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 03:10:12 UTC 2024 - 60.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
val source = stream.getSource() val out = stream.getSink().buffer() source.close() assertFailsWith<IOException> { source.read(Buffer(), 1) }.also { expected -> assertThat(expected.message).isEqualTo("stream closed") } out.writeUtf8("square") out.flush() out.close() assertThat(connection.openStreamCount()).isEqualTo(0)
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 75.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
Request.Builder() .url(server.url("/")) .build(), ).execute().close() listener.removeUpToEvent<CallEnd>() val call = client.newCall( Request.Builder() .url(server.url("/")) .build(), ) val response = call.execute() response.close() assertThat(listener.recordedEventTypes()).containsExactly( "CallStart",
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (0) -
src/net/http/request.go
// is responsible for calling the Close method. // // For server requests, the Request Body is always non-nil // but will return EOF immediately when no body is present. // The Server will close the request body. The ServeHTTP // Handler does not need to. // // Body must allow Read to be called concurrently with Close. // In particular, calling Close should unblock a Read waiting // for input.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 49.4K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/test/groovy/org/gradle/model/internal/registry/DefaultModelRegistryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 56K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/CopyUtil.java
try { return copyInternal(is, os); } finally { CloseableUtil.close(os); } } finally { CloseableUtil.close(is); } } /** * 指定されたエンコーディングのファイルからプラットフォームデフォルトエンコーディングのファイルへコピーします。 * * @param in
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 52.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
lastObservedRV := uint64(0) for { select { case err := <-errc: t.Fatal(err) return case event, ok := <-w.ResultChan(): if !ok { t.Fatal("Unexpected closed") } rv, err := cacher.versioner.ObjectResourceVersion(event.Object) if err != nil { t.Errorf("failed to parse resource version from %#v: %v", event.Object, err) } if event.Type == watch.Bookmark {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/controller/endpoint/endpoints_controller_test.go
return controller.queue.Len() == 0, nil }) // Cause test server to delete endpoints close(blockDelete) waitForChanReceive(t, 1*time.Second, blockNextAction, "Endpoint should have been recreated") close(blockNextAction) close(stopChan) } func TestSyncServiceAddresses(t *testing.T) { makeService := func(tolerateUnready bool) *v1.Service {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 87.7K bytes - Viewed (0)