- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for payload (0.45 sec)
-
internal/grid/README.md
The server handler function has this signature: `type SingleHandlerFn func(payload []byte) ([]byte, *RemoteErr)`. Sample handler: ```go handler := func(payload []byte) ([]byte, *grid.RemoteErr) { // Do something with payload return []byte("response"), nil } err := manager.RegisterSingleHandler(grid.HandlerDiskInfo, handler) ```
Plain Text - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 9.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketReader.kt
import okhttp3.internal.ws.WebSocketProtocol.OPCODE_FLAG_CONTROL import okhttp3.internal.ws.WebSocketProtocol.OPCODE_TEXT import okhttp3.internal.ws.WebSocketProtocol.PAYLOAD_BYTE_MAX import okhttp3.internal.ws.WebSocketProtocol.PAYLOAD_LONG import okhttp3.internal.ws.WebSocketProtocol.PAYLOAD_SHORT import okhttp3.internal.ws.WebSocketProtocol.toggleMask import okio.Buffer import okio.BufferedSource import okio.ByteString /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketWriterTest.kt
val payload = Buffer() while (payload.completeSegmentByteCount() <= PAYLOAD_BYTE_MAX) { payload.writeByte('0'.code) } serverWriter.writeMessageFrame(OPCODE_BINARY, payload.snapshot()) // Write directly to the unbuffered sink. This ensures it will become single frame. assertData("827e") // 'e' == 4-byte follow-up length. assertData(format("%04X", payload.completeSegmentByteCount()))
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 9.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt
/** Send a ping with the supplied [payload]. */ @Throws(IOException::class) fun writePing(payload: ByteString) { writeControlFrame(OPCODE_CONTROL_PING, payload) } /** Send a pong with the supplied [payload]. */ @Throws(IOException::class) fun writePong(payload: ByteString) { writeControlFrame(OPCODE_CONTROL_PONG, payload) } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.9K bytes - Viewed (0) -
docs/en/docs/advanced/generate-clients.md
=== "Python 3.8+" ```Python hl_lines="9-11 14-15 18 19 23" {!> ../../../docs_src/generate_clients/tutorial001.py!} ``` Notice that the *path operations* define the models they use for request payload and response payload, using the models `Item` and `ResponseMessage`. ### API Docs If you go to the API docs, you will see that it has the **schemas** for the data to be sent in requests and received in responses:
Plain Text - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Thu Apr 18 19:53:19 GMT 2024 - 10.5K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketProtocol.kt
* special values [PAYLOAD_SHORT] or [PAYLOAD_LONG]. */ internal const val PAYLOAD_BYTE_MAX = 125L /** Maximum length of close message in bytes. */ internal const val CLOSE_MESSAGE_MAX = PAYLOAD_BYTE_MAX - 2 /** * Value for [B1_MASK_LENGTH] which indicates the next two bytes are the unsigned length. */ internal const val PAYLOAD_SHORT = 126
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 4.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
} fun assertTextMessage(payload: String?) { assertThat(nextEvent()).isEqualTo(Message(string = payload)) } fun assertBinaryMessage(payload: ByteString?) { assertThat(nextEvent()).isEqualTo(Message(payload)) } fun assertPing(payload: ByteString) { assertThat(nextEvent()).isEqualTo(Ping(payload)) } fun assertPong(payload: ByteString) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 6.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/Http2Test.kt
requireSettings = false, object : BaseTestHandler() { override fun ping( ack: Boolean, payload1: Int, payload2: Int, ) { assertThat(ack).isTrue() assertThat(payload1).isEqualTo(expectedPayload1) assertThat(payload2).isEqualTo(expectedPayload2) } }, ) } @Test fun maxLengthDataFrame() {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 28.1K bytes - Viewed (0) -
docs/sts/wso2.md
"token_type": "Bearer", "expires_in": 3600 } ``` ### 4. JWT Claims The id_token received is a signed JSON Web Token (JWT). Use a JWT decoder to decode the id_token to access the payload of the token that includes following JWT claims:
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 8.7K bytes - Viewed (0) -
docs/select/README.md
'CSV': { "FileHeaderInfo": "USE", }, 'CompressionType': 'GZIP', }, OutputSerialization={'CSV': {}}, ) for event in r['Payload']: if 'Records' in event: records = event['Records']['Payload'].decode('utf-8') print(records) elif 'Stats' in event: statsDetails = event['Stats']['Details'] print("Stats details bytesScanned: ")
Plain Text - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Sep 29 04:28:45 GMT 2022 - 6.5K bytes - Viewed (0)