- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 174 for SEND (0.02 seconds)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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 responseCreated: Sat Dec 20 13:44:44 GMT 2025 - Last Modified: Sun Aug 31 08:00:57 GMT 2025 - 11.1K bytes - Click Count (0)