- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 1,978 for seni (0.06 sec)
-
test/typeparam/orderedmapsimp.dir/a.go
return s, r } // A Sender is used to send values to a Receiver. type Sender[Elem any] struct { values chan<- Elem done <-chan struct{} } // Send sends a value to the receiver. It reports whether the value was sent. // The value will not be sent if the context is closed or the receiver // is freed. func (s *Sender[Elem]) Send(ctx context.Context, v Elem) bool { select { case <-ctx.Done():
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jul 28 21:40:40 UTC 2021 - 5.5K bytes - Viewed (0) -
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) -
internal/grid/stream.go
responses <-chan Response cancel context.CancelCauseFunc // Requests sent to the server. // If the handler is defined with 0 incoming capacity this will be nil. // Channel *must* be closed to signal the end of the stream. // If the request context is canceled, the stream will no longer process requests. // Requests sent cannot be used any further by the called. Requests chan<- []byte muxID uint64
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Writer.kt
flags = FLAG_ACK, ) sink.flush() } } /** * HTTP/2 only. Send a push promise header block. * * A push promise contains all the headers that pertain to a server-initiated request, and a * `promisedStreamId` to which response frames will be delivered. Push promise frames are sent as * a part of the response to `streamId`. The `promisedStreamId` has a priority of one greater than
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 11.3K 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) -
pkg/xds/server.go
// allow both wildcard and non-wildcard subscriptions. Wildcard bool // NonceSent is the nonce sent in the last sent response. If it is equal with NonceAcked, the // last message has been processed. If empty: we never sent a message of this type. NonceSent string // NonceAcked is the last acked message. NonceAcked string
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 20:55:20 UTC 2024 - 16.3K 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)