- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 642 for seni (0.05 sec)
-
docs_src/background_tasks/tutorial002.py
background_tasks.add_task(write_log, message) return q @app.post("/send-notification/{email}") async def send_notification( email: str, background_tasks: BackgroundTasks, q: str = Depends(get_query) ): message = f"message to {email}\n" background_tasks.add_task(write_log, message)
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat May 14 11:59:59 UTC 2022 - 675 bytes - Viewed (0) -
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/StreamedValueListener.java
* limitations under the License. */ package org.gradle.tooling; import org.gradle.api.Incubating; /** * Receives a value sent via {@link BuildController#send(Object)}. * * <p>Objects are received in the order they were sent and all objects are received before the result of the {@link BuildAction} is returned to the application.</p> * * @since 8.6 */ @Incubating
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 19 08:15:25 UTC 2023 - 1.1K bytes - Viewed (0) -
internal/event/target/mqtt.go
return err } // Do not send if the connection is not active. _, err := target.isActive() if err != nil { return err } eventData, err := target.store.Get(key.Name) if err != nil { // The last event key in a successful batch will be sent in the channel atmost once by the replayEvents() // Such events will not exist and wouldve been already been sent successfully. if os.IsNotExist(err) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 8.2K bytes - Viewed (0) -
cmd/metrics-v3-cluster-notification.go
notificationEventsErrorsTotalMD = NewCounterMD(notificationEventsErrorsTotal, "Events that were failed to be sent to the targets") notificationEventsSentTotalMD = NewCounterMD(notificationEventsSentTotal, "Total number of events sent to the targets")
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Apr 24 04:10:35 UTC 2024 - 2.2K bytes - Viewed (0) -
docs_src/background_tasks/tutorial002_an_py39.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 696 bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
assert.Equal(t, m.Payload.(*zdsapi.WorkloadRequest_Add).Add.Uid, uid) // send ack so the server doesn't wait for us. sendAck(ztunClient) // second message should be the snap sent message m, fds = readRequest(t, ztunClient) assert.Equal(t, len(fds), 0) sent := m.Payload.(*zdsapi.WorkloadRequest_SnapshotSent).SnapshotSent if sent == nil { panic("expected snapshot sent") } sendAck(ztunClient) ztunClient.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0) -
docs_src/background_tasks/tutorial002_an.py
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 725 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/WebSocket.kt
* closing, closed, or canceled. * * This method returns immediately. */ fun send(bytes: ByteString): Boolean /** * Attempts to initiate a graceful shutdown of this web socket. Any already-enqueued messages will * be transmitted before the close message is sent but subsequent calls to [send] will return * false and their messages will not be enqueued. *
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/hbone/util.go
// Server side HTTP stream. For client side, FIN can be sent by closing the pipe (or // request body). For server, the FIN will be sent when the handler returns - but // this only happen after request is completed and body has been read. If server wants // to send FIN first - while still reading the body - we are in trouble. // That means HTTP2 TCP servers provide no way to send a FIN from server, without // having the request fully read.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 3.4K bytes - Viewed (0) -
docs_src/background_tasks/tutorial002_py310.py
background_tasks.add_task(write_log, message) return q @app.post("/send-notification/{email}") async def send_notification( email: str, background_tasks: BackgroundTasks, q: str = Depends(get_query) ): message = f"message to {email}\n" background_tasks.add_task(write_log, message)
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Fri Jan 07 14:11:31 UTC 2022 - 643 bytes - Viewed (0)