- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 373 for closeFn (0.17 sec)
-
platforms/core-runtime/client-services/src/test/groovy/org/gradle/internal/daemon/client/clientinput/DaemonClientInputForwarderTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue May 28 12:11:05 UTC 2024 - 5K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/test/groovy/org/gradle/internal/daemon/clientinput/StdInStreamTest.groovy
} def "read byte returns when stream is closed"() { def dispatch = Mock(OutputEventListener) def stream = new StdInStream(dispatch) when: async { start { def b1 = stream.read() assert b1 == -1 } thread.blockUntil.requested stream.close() } then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 5.2K bytes - Viewed (0) -
src/net/http/server.go
listenerGroup sync.WaitGroup } // Close immediately closes all active net.Listeners and any // connections in state [StateNew], [StateActive], or [StateIdle]. For a // graceful shutdown, use [Server.Shutdown]. // // Close does not attempt to close (and does not even know about) // any hijacked connections, such as WebSockets. // // Close returns any error returned from closing the [Server]'s
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 123.4K bytes - Viewed (0) -
src/net/http/serve_test.go
} t.Cleanup(func() { bresp.Body.Close() }) // Try to cause a race. Canceling the client request will cause the client // transport to close req2.Body. Returning from the server handler will // cause the server to close req.Body. Since they are the same underlying // ReadCloser, that will result in concurrent calls to Close (and possibly a // Read concurrent with a Close). if mode == http2Mode {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 17:57:01 UTC 2024 - 202K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/watch/watch.go
type Interface interface { // Stop tells the producer that the consumer is done watching, so the // producer should stop sending events and close the result channel. The // consumer should keep watching for events until the result channel is // closed. // // Because some implementations may create channels when constructed, Stop // must always be called, even if the consumer has not yet called // ResultChan().
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:06:22 UTC 2024 - 8.1K bytes - Viewed (1) -
src/net/http/clientserver_test.go
t.Fatal(err) } defer c.Close() fmt.Fprintln(c, "some bogus crap") })) closes := 0 res, err := cst.c.Post(cst.ts.URL, "text/plain", countCloseReader{&closes, strings.NewReader("hello")}) if err == nil { res.Body.Close() t.Fatal("expected an error to be returned from Post") } if closes != 1 { t.Errorf("closes = %d; want 1", closes) } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 46.6K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/service/scopes/DefaultGradleUserHomeScopeServiceRegistryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon May 27 12:34:44 UTC 2024 - 8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ResponseBodyJvmTest.kt
@Throws(IOException::class) override fun close() { closed.set(true) super.close() } }.buffer() } } body.charStream().close() assertThat(closed.get()).isTrue() } @Test fun readerClosedAfterBomClosesUnderlyingSource() { val closed = AtomicBoolean() val body: ResponseBody =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon May 13 13:42:37 UTC 2024 - 13K bytes - Viewed (0) -
src/cmd/internal/objabi/pkgspecial.go
NoRaceFunc bool // AllowAsmABI indicates that assembly in this package is allowed to use ABI // selectors in symbol names. Generally this is needed for packages that // interact closely with the runtime package or have performance-critical // assembly. AllowAsmABI bool } var runtimePkgs = []string{ "runtime", "internal/runtime/atomic", "internal/runtime/exithook",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 02:32:19 UTC 2024 - 3.8K bytes - Viewed (0) -
src/runtime/chan.go
if c == nil { panic(plainError("close of nil channel")) } lock(&c.lock) if c.closed != 0 { unlock(&c.lock) panic(plainError("close of closed channel")) } if raceenabled { callerpc := getcallerpc() racewritepc(c.raceaddr(), callerpc, abi.FuncPCABIInternal(closechan)) racerelease(c.raceaddr()) } c.closed = 1 var glist gList
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:50 UTC 2024 - 25.9K bytes - Viewed (0)