- Sort Score
- Num 10 results
- Language All
Results 11 - 20 of 1,090 for Messages (0.36 seconds)
-
docs/en/docs/advanced/websockets.md
**FastAPI** provides the same `WebSocket` directly just as a convenience for you, the developer. But it comes directly from Starlette. /// ## Await for messages and send messages { #await-for-messages-and-send-messages } In your WebSocket route you can `await` for messages and send messages. {* ../../docs_src/websockets/tutorial001_py39.py hl[48:52] *} You can receive and send binary, text, and JSON data. ## Try it { #try-it }Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 5.7K bytes - Click Count (0) -
docs/bucket/notifications/README.md
delivery_mode (number) set to '1' for non-persistent or '2' for persistent queue queue_dir (path) staging dir for undelivered messages e.g. '/home/events' queue_limit (number) maximum limit for undelivered messages, defaults to '100000' comment (sentence) optionally add a comment to this setting ``` Or environment variables ``` KEY:
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Aug 12 18:20:36 GMT 2025 - 84.2K bytes - Click Count (0) -
docs_src/websockets/tutorial001_py39.py
</form> <ul id='messages'> </ul> <script> var ws = new WebSocket("ws://localhost:8000/ws"); ws.onmessage = function(event) { var messages = document.getElementById('messages') var message = document.createElement('li') var content = document.createTextNode(event.data) message.appendChild(content)Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 1.4K bytes - Click Count (0) -
docs_src/websockets/tutorial002_py39.py
ws.onmessage = function(event) { var messages = document.getElementById('messages') var message = document.createElement('li') var content = document.createTextNode(event.data) message.appendChild(content) messages.appendChild(message) }; event.preventDefault() }
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Wed Dec 17 20:41:43 GMT 2025 - 2.8K bytes - Click Count (0) -
docs_src/websockets/tutorial003_py39.py
</form> <ul id='messages'> </ul> <script> var client_id = Date.now() document.querySelector("#ws-id").textContent = client_id; var ws = new WebSocket(`ws://localhost:8000/ws/${client_id}`); ws.onmessage = function(event) { var messages = document.getElementById('messages') var message = document.createElement('li')Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Mar 18 12:29:59 GMT 2023 - 2.5K bytes - Click Count (0) -
cmd/metrics-v3-audit.go
) var ( auditFailedMessagesMD = NewCounterMD(auditFailedMessages, "Total number of messages that failed to send since start", targetID) auditTargetQueueLengthMD = NewGaugeMD(auditTargetQueueLength, "Number of unsent messages in queue for target", targetID) auditTotalMessagesMD = NewCounterMD(auditTotalMessages, "Total number of messages sent since start", targetID) ) // loadAuditMetrics - `MetricsLoaderFn` for audit
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri May 10 14:50:39 GMT 2024 - 1.9K bytes - Click Count (0) -
mockwebserver/README.md
chat.loadMore(); assertEquals("hello, world!", chat.messages()); chat.loadMore(); chat.loadMore(); assertEquals("" + "hello, world!\n" + "sup, bra?\n" + "yo dog", chat.messages()); // Optional: confirm that your app made the HTTP requests you were expecting. RecordedRequest request1 = server.takeRequest(); assertEquals("/v1/chat/messages/", request1.getUrl().encodedPath());
Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Oct 30 21:39:59 GMT 2025 - 8.1K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/RealWebSocket.kt
} } try { if (pong != null) { writer!!.writePong(pong) } else if (messageOrClose is Message) { val message = messageOrClose writer!!.writeMessageFrame(message.formatOpcode, message.data) synchronized(this) { queueSize -= message.data.size.toLong() } } else if (messageOrClose is Close) { val close = messageOrCloseCreated: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Thu Jul 31 04:18:40 GMT 2025 - 21.6K bytes - Click Count (0) -
internal/deadlineconn/deadlineconn_test.go
} if received != "messages received\n" { t.Fatalf(`client: expected: "messages received\n", got: %v`, received) } wg.Wait() } // Test deadlineconn handles read timeout properly by reading two messages beyond deadline. func TestBuffConnReadCheckTimeout(t *testing.T) { l, err := net.Listen("tcp", "localhost:0") if err != nil { t.Fatalf("unable to create listener. %v", err) } defer l.Close()Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon Nov 11 17:15:17 GMT 2024 - 4.8K bytes - Click Count (0) -
cmd/metrics-v3-logger-webhook.go
webhookFailedMessagesMD = NewCounterMD(webhookFailedMessages, "Number of messages that failed to send", allWebhookLabels...) webhookQueueLengthMD = NewGaugeMD(webhookQueueLength, "Webhook queue length", allWebhookLabels...) webhookTotalMessagesMD = NewCounterMD(webhookTotalMessages, "Total number of messages sent to this target", allWebhookLabels...) )
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue May 14 07:27:33 GMT 2024 - 2K bytes - Click Count (0)