Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 11 - 20 of 1,090 for Messages (0.36 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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 = messageOrClose
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 21.6K bytes
    - Click Count (0)
  9. 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)
  10. 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)
Back to Top