Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 426 for shend (0.19 sec)

  1. tests/test_tutorial/test_websockets/test_tutorial002_an_py39.py

                message = "Message one"
                websocket.send_text(message)
                data = websocket.receive_text()
                assert data == "Session cookie or query token value is: fakesession"
                data = websocket.receive_text()
                assert data == f"Message text was: {message}, for item ID: foo"
                message = "Message two"
                websocket.send_text(message)
                data = websocket.receive_text()
    Python
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sat Mar 18 12:29:59 GMT 2023
    - 3.9K bytes
    - Viewed (0)
  2. internal/grid/muxserver.go

    	go func() {
    		wg.Wait()
    		defer xioutil.SafeClose(send)
    		err := m.handleRequests(ctx, msg, send, handler, handlerIn)
    		if err != nil {
    			handlerErr.Store(err)
    		}
    	}()
    
    	// Response sender goroutine...
    	go func(outBlock <-chan struct{}) {
    		wg.Wait()
    		defer m.parent.deleteMux(true, m.ID)
    		m.sendResponses(ctx, send, c, &handlerErr, outBlock)
    	}(m.outBlock)
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 9.1K bytes
    - Viewed (0)
  3. docs_src/websockets/tutorial002_py310.py

    ):
        await websocket.accept()
        while True:
            data = await websocket.receive_text()
            await websocket.send_text(
                f"Session cookie or query token value is: {cookie_or_token}"
            )
            if q is not None:
                await websocket.send_text(f"Query parameter q is: {q}")
    Python
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sat Mar 18 12:29:59 GMT 2023
    - 2.7K bytes
    - Viewed (0)
  4. internal/config/lambda/event/targetlist.go

    	for k, v := range list.targets {
    		ntargets[k] = v
    	}
    	return ntargets
    }
    
    // Send - sends events to targets identified by target IDs.
    func (list *TargetList) Send(event Event, id TargetID) (*http.Response, error) {
    	list.RLock()
    	target, ok := list.targets[id]
    	list.RUnlock()
    	if ok {
    		return target.Send(event)
    	}
    	return nil, ErrARNNotFound{}
    }
    
    // Stats returns stats for targets.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Mar 07 16:12:41 GMT 2023
    - 4.3K bytes
    - Viewed (0)
  5. docs_src/websockets/tutorial001.py

        </head>
        <body>
            <h1>WebSocket Chat</h1>
            <form action="" onsubmit="sendMessage(event)">
                <input type="text" id="messageText" autocomplete="off"/>
                <button>Send</button>
            </form>
            <ul id='messages'>
            </ul>
            <script>
                var ws = new WebSocket("ws://localhost:8000/ws");
                ws.onmessage = function(event) {
    Python
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Thu Mar 26 19:09:53 GMT 2020
    - 1.4K bytes
    - Viewed (0)
  6. api/maven-api-core/src/main/java/org/apache/maven/api/plugin/Log.java

        /**
         * @return true if the <b>debug</b> error level is enabled
         */
        boolean isDebugEnabled();
    
        /**
         * Send a message to the user in the <b>debug</b> error level.
         *
         * @param content
         */
        void debug(CharSequence content);
    
        /**
         * Send a message (and accompanying exception) to the user in the <b>debug</b> error level.<br>
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Wed Feb 28 23:54:53 GMT 2024
    - 5.1K bytes
    - Viewed (0)
  7. internal/grid/muxclient.go

    		var cancel context.CancelFunc
    		ctx, cancel = context.WithTimeout(ctx, defaultSingleRequestTimeout)
    		defer cancel()
    	}
    	// Send request
    	if err := m.send(msg); err != nil {
    		return nil, err
    	}
    	if debugReqs {
    		fmt.Println(m.MuxID, m.parent.String(), "SEND")
    	}
    	// Wait for response or context.
    	select {
    	case v, ok := <-ch:
    		if !ok {
    			return nil, ErrDisconnected
    		}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 14.2K bytes
    - Viewed (0)
  8. docs_src/websockets/tutorial003_py39.py

            self.active_connections.remove(websocket)
    
        async def send_personal_message(self, message: str, websocket: WebSocket):
            await websocket.send_text(message)
    
        async def broadcast(self, message: str):
            for connection in self.active_connections:
                await connection.send_text(message)
    
    
    manager = ConnectionManager()
    
    
    @app.get("/")
    async def get():
    Python
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Sat Mar 18 12:29:59 GMT 2023
    - 2.5K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbTreeHandleImpl.java

            return send(req, null, params);
        }
    
    
        /**
         * @param request
         * @param response
         * @param params
         * @return response
         * @throws CIFSException
         */
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Sun Jul 01 13:12:10 GMT 2018
    - 8.9K bytes
    - Viewed (0)
  10. docs/en/docs/advanced/openapi-webhooks.md

    This is normally called a **webhook**.
    
    ## Webhooks steps
    
    The process normally is that **you define** in your code what is the message that you will send, the **body of the request**.
    
    You also define in some way at which **moments** your app will send those requests or events.
    
    Plain Text
    - Registered: Sun Apr 28 07:19:10 GMT 2024
    - Last Modified: Fri Jun 30 18:25:16 GMT 2023
    - 2.8K bytes
    - Viewed (0)
Back to top