Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 174 for SEND (0.02 seconds)

  1. 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
    		}
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 15.9K bytes
    - Click Count (0)
  2. tests/test_sub_callbacks.py

        And this path operation will:
    
        * Send the invoice to the client.
        * Collect the money from the client.
        * Send a notification back to the API user (the external developer), as a callback.
            * At this point is that the API will somehow send a POST request to the
                external API with the notification of the invoice event
                (e.g. "payment successful").
        """
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Sat Dec 27 18:19:10 GMT 2025
    - 12.9K bytes
    - Click Count (0)
  3. docs/en/docs/advanced/websockets.md

    ///
    
    ## 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 }
    
    If your file is named `main.py`, run your application with:
    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)
  4. docs_src/openapi_callbacks/tutorial001_py310.py

        And this path operation will:
    
        * Send the invoice to the client.
        * Collect the money from the client.
        * Send a notification back to the API user (the external developer), as a callback.
            * At this point is that the API will somehow send a POST request to the
                external API with the notification of the invoice event
                (e.g. "payment successful").
        """
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Wed Dec 10 08:55:32 GMT 2025
    - 1.3K bytes
    - Click Count (0)
  5. fastapi/middleware/asyncexitstack.py

            async with AsyncExitStack() as stack:
                scope[self.context_name] = stack
    Created: Sun Dec 28 07:19:09 GMT 2025
    - Last Modified: Mon Sep 29 03:29:38 GMT 2025
    - 637 bytes
    - Click Count (0)
  6. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

        server.send(message3)
        clientListener.assertTextMessage(message3)
    
        // Empty client to server message.
        val message4 = ""
        client.send(message4)
        serverListener.assertTextMessage(message4)
    
        // Server to client message that shares context with message1.
        val message5 = message1 + message1
        server.send(message5)
        clientListener.assertTextMessage(message5)
    
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
  7. internal/logger/target/http/http.go

    	// assign the new webhook target to this field.
    	// The Send() method will then re-direct entries
    	// to the new target when the current one
    	// has been set to status "statusClosed".
    	// Once the glogal target slice has been migrated
    	// the current target will stop receiving entries.
    	migrateTarget *Target
    
    	// Number of events per HTTP send to webhook target
    	// this is ideally useful only if your endpoint can
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  8. internal/config/lambda/event/targetlist.go

    	maps.Copy(ntargets, list.targets)
    	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.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  9. src/main/java/jcifs/smb/SmbPipeHandleImpl.java

                        req.setMaxDataCount(1024);
                    }
                    th.send(req, resp, RequestParam.NO_RETRY);
                    return resp.getResponseLength();
                }
                if (this.call) {
                    th.send(new TransWaitNamedPipe(th.getConfig(), this.uncPath), new TransWaitNamedPipeResponse(th.getConfig()));
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  10. src/main/java/jcifs/smb/SmbTreeHandleImpl.java

         * @param params
         * @return response
         * @throws CIFSException
         */
        public <T extends CommonServerMessageBlockResponse> T send(final jcifs.internal.Request<T> req, final RequestParam... params)
                throws CIFSException {
            return send(req, null, params);
        }
    
        /**
         * @param request
         * @param response
         * @param params
         * @return response
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 11.1K bytes
    - Click Count (0)
Back to Top