- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 3,889 for close1 (0.12 sec)
-
okhttp/src/test/java/okhttp3/ResponseBodyTest.kt
val source = Buffer().writeUtf8("hello") return object : ForwardingSource(source) { override fun close() { closed = true super.close() } }.buffer() } } body.source().close() assertThat(closed).isTrue() } @Test fun throwingUnderlyingSourceClosesQuietly() { val body: ResponseBody =
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4K bytes - Viewed (1) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
} } /** * Closes this connection. This cancels all open streams and unanswered pings. It closes the * underlying input and output streams and shuts down internal task queues. */ override fun close() { close(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null) } internal fun close( connectionCode: ErrorCode, streamCode: ErrorCode,
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
src/main/java/jcifs/context/AbstractCIFSContext.java
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Tue Jul 07 10:50:16 UTC 2020 - 3.7K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketPolicy.kt
* and [ShutdownOutputAtEnd] that close a socket after a response, and where there are * follow-up requests. The client is unblocked and free to continue as soon as it has received the * entire response body. If and when the client makes a subsequent request using a pooled socket the * server may not have had time to close the socket. The socket will be closed at an indeterminate
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0) -
src/go/parser/testdata/chans.go2
func (s *Sender[T]) Send(v T) bool { select { case s.values <- v: return true case <-s.done: return false } } // Close tells the receiver that no more values will arrive. // After Close is called, the Sender may no longer be used. func (s *Sender[T]) Close() { close(s.values) } // A Receiver receives values from a Sender. type Receiver[T any] struct { values <-chan T done chan<- bool }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 24 19:44:06 UTC 2020 - 1.7K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/MultipartReader.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.1K bytes - Viewed (0) -
android/guava/src/com/google/common/io/AppendableWriter.java
checkNotClosed(); if (target instanceof Flushable) { ((Flushable) target).flush(); } } @Override public void close() throws IOException { this.closed = true; if (target instanceof Closeable) { ((Closeable) target).close(); } } @Override public Writer append(char c) throws IOException { checkNotClosed(); target.append(c); return this;
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 28 20:13:02 UTC 2023 - 3.4K bytes - Viewed (0) -
pkg/volume/csi/csi_client.go
nodeClient csipbv1.NodeClient, closer io.Closer, err error, ) type nodeV1AccessModeMapper func(am api.PersistentVolumeAccessMode) csipbv1.VolumeCapability_AccessMode_Mode // newV1NodeClient creates a new NodeClient with the internally used gRPC // connection set up. It also returns a closer which must be called to close // the gRPC connection when the NodeClient is not used anymore.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 20 10:15:36 UTC 2022 - 22.1K bytes - Viewed (0) -
pilot/pkg/server/instance_test.go
} }) } } type reclosableChannel struct { c chan struct{} closed bool } func newReclosableChannel() *reclosableChannel { return &reclosableChannel{ c: make(chan struct{}), } } func (c *reclosableChannel) Close() { if !c.closed { c.closed = true close(c.c) } } type fakeComponent struct { started *atomic.Bool completed *atomic.Bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 23:02:39 UTC 2024 - 4.1K bytes - Viewed (0)