- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 867 for Closes (0.18 sec)
-
internal/s3select/simdj/reader.go
if !ok { dstRec = &Record{} } dstRec.object = v return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. // Potentially racy if the stream decoder is still reading. if r.readCloser != nil { r.readCloser.Close() } if r.exitReader != nil { close(r.exitReader) r.readerWg.Wait() r.exitReader = nil r.input = nil } return nil }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Tue May 30 17:02:22 GMT 2023 - 4.9K bytes - Viewed (0) -
internal/s3select/json/reader.go
} dstRec.KVS = kvs dstRec.SelectFormat = sql.SelectFmtJSON return dstRec, nil } // Close - closes underlying reader. func (r *Reader) Close() error { // Close the input. err := r.readCloser.Close() for range r.valueCh { // Drain values so we don't leak a goroutine. // Since we have closed the input, it should fail rather quickly. } return err }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Mar 24 03:58:53 GMT 2022 - 3K bytes - Viewed (0) -
internal/grid/stream.go
// the appropriate error will be returned. type Stream struct { // responses from the remote server. // Channel will be closed after error or when remote closes. // All responses *must* be read by the caller until either an error is returned or the channel is closed. // Canceling the context will cause the context cancellation error to be returned. responses <-chan Response cancel context.CancelCauseFunc
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed Feb 28 18:05:18 GMT 2024 - 2.8K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/Response.kt
fun receivedResponseAtMillis(): Long = receivedResponseAtMillis /** * Closes the response body. Equivalent to `body().close()`. * * Prior to OkHttp 5.0, it was an error to close a response that is not eligible for a body. This * includes the responses returned from [cacheResponse], [networkResponse], and [priorResponse]. */ override fun close() = commonClose() override fun toString(): String = commonToString()
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 23 14:31:42 GMT 2024 - 15.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
@SafeVarargs internal fun <T> immutableListOf(vararg elements: T): List<T> { return Collections.unmodifiableList(listOf(*elements.clone())) } /** Closes this, ignoring any checked exceptions. */ internal fun Socket.closeQuietly() { try { close() } catch (e: AssertionError) { throw e } catch (rethrown: RuntimeException) { if (rethrown.message == "bio == null") {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Tue Jan 09 12:33:05 GMT 2024 - 10.5K bytes - Viewed (0) -
internal/http/check_port_linux.go
l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks. return l.Close()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbComWrite.java
this.b = b; this.off = off; count = len; digest = null; /* otherwise recycled commands * like writeandx will choke if session * closes in between */ } int writeParameterWordsWireFormat( byte[] dst, int dstIndex ) { int start = dstIndex; writeInt2( fid, dst, dstIndex ); dstIndex += 2;
Java - Registered: Sun Apr 28 00:10:09 GMT 2024 - Last Modified: Fri Mar 22 21:10:40 GMT 2019 - 3K bytes - Viewed (0) -
internal/http/check_port_others.go
l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err } // As we are able to listen on this network, the port is not in use. // Close the listener and continue check other networks. return l.Close()
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Wed May 03 21:12:25 GMT 2023 - 1.5K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/cache2/RelayTest.kt
val relay = edit(file, upstream, metadata, 1024) val source1 = relay.newSource() val source2 = relay.newSource() source1!!.close() source1.close() // Unnecessary. Shouldn't decrement the reference count. assertThat(relay.isClosed).isFalse() source2!!.close() assertThat(relay.isClosed).isTrue() assertFile(Relay.PREFIX_DIRTY, -1L, -1, null, null) } @Test fun racingReaders() {
Plain Text - Registered: Fri Apr 26 11:42:10 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 8.1K bytes - Viewed (0) -
internal/dsync/locker.go
ForceUnlock(ctx context.Context, args LockArgs) (bool, error) // Returns underlying endpoint of this lock client instance. String() string // Close closes any underlying connection to the service endpoint Close() error // Is the underlying connection online? (is always true for any local lockers) IsOnline() bool // Is the underlying locker local to this server? IsLocal() bool
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Tue Jan 18 20:44:38 GMT 2022 - 2.7K bytes - Viewed (0)