- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for writeClose (0.04 sec)
-
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
* [Section 7.4 of RFC 6455](http://tools.ietf.org/html/rfc6455#section-7.4) or `0`. * @param reason Reason for shutting down or `null`. */ @Throws(IOException::class) fun writeClose( code: Int, reason: ByteString?, ) { var payload = ByteString.EMPTY if (code != 0 || reason != null) { if (code != 0) { validateCloseCode(code) } payload =
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
synchronized(this) { queueSize -= message.data.size.toLong() } } else if (messageOrClose is Close) { val close = messageOrClose writer!!.writeClose(close.code, close.reason) // We closed the writer: now both reader and writer are closed. if (sendOnClosed) { listener.onClosed(this, receivedCloseCode, receivedCloseReason!!) }
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 21.6K bytes - Viewed (0) -
cmd/object-api-datatypes.go
UserTags string // List of individual parts, maximum size of upto 10,000 Parts []ObjectPartInfo `json:"-"` // Implements writer and reader used by CopyObject API Writer io.WriteCloser `json:"-" msg:"-"` Reader *hash.Reader `json:"-" msg:"-"` PutObjReader *PutObjReader `json:"-" msg:"-"` metadataOnly bool versionOnly bool // adds a new version, only used by CopyObject
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 21.2K bytes - Viewed (0)