- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 265 for eventbus (0.12 sec)
-
okhttp-sse/src/main/kotlin/okhttp3/sse/EventSourceListener.kt
*/ package okhttp3.sse import okhttp3.Response abstract class EventSourceListener { /** * Invoked when an event source has been accepted by the remote peer and may begin transmitting * events. */ open fun onOpen( eventSource: EventSource, response: Response, ) { } /** * TODO description. */ open fun onEvent( eventSource: EventSource, id: String?,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.5K bytes - Viewed (0) -
docs/zh/docs/advanced/openapi-callbacks.md
``` https://yourapi.com/invoices/?callback_url=https://www.external.org/events ``` 使用如下 JSON 请求体: ```JSON { "id": "2expen51ve", "customer": "Mr. Richie Rich", "total": "9999" } ``` 然后,您的 API 就会处理发票,并在某个点之后,发送回调请求至 `callback_url`(外部 API): ``` https://www.external.org/events/invoices/2expen51ve ``` JSON 请求体包含如下内容: ```JSON {
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 6.6K bytes - Viewed (0) -
docs/de/docs/advanced/openapi-webhooks.md
Sie definieren auch auf irgendeine Weise, zu welchen **Momenten** Ihre Anwendung diese Requests oder Events sendet. Und **Ihre Benutzer** definieren auf irgendeine Weise (zum Beispiel irgendwo in einem Web-Dashboard) die **URL**, an die Ihre Anwendung diese Requests senden soll.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 3.3K bytes - Viewed (0) -
docs/de/docs/advanced/openapi-callbacks.md
https://yourapi.com/invoices/?callback_url=https://www.external.org/events ``` mit einem JSON-Körper: ```JSON { "id": "2expen51ve", "customer": "Mr. Richie Rich", "total": "9999" } ``` dann verarbeitet *Ihre API* die Rechnung und sendet irgendwann später einen Callback-Request an die `callback_url` (die *externe API*): ``` https://www.external.org/events/invoices/2expen51ve ```
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 8.8K bytes - Viewed (0) -
internal/event/targetlist.go
targetStats map[TargetID]targetStat } type targetStat struct { // The number of concurrent async Send calls per targets currentSendCalls int64 // The number of total events per target totalEvents int64 // The number of failed events per target failedEvents int64 } func (list *TargetList) getStatsByTargetID(id TargetID) (stat targetStat) { list.statLock.RLock() defer list.statLock.RUnlock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 9.2K bytes - Viewed (0) -
docs/bucket/lifecycle/README.md
aws s3api restore-object --bucket srcbucket \ --key object \ --restore-request Days=3 ``` ### 4.1 Monitoring transition events `s3:ObjectTransition:Complete` and `s3:ObjectTransition:Failed` events can be used to monitor transition events between the source cluster and transition tier. To watch lifecycle events, you can enable bucket notification on the source bucket with `mc event add` and specify `--event ilm` flag.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jul 09 01:45:38 UTC 2024 - 9K bytes - Viewed (0) -
internal/event/config.go
parsedQueue := queue{} if err := d.DecodeElement(&parsedQueue, &start); err != nil { return err } if len(parsedQueue.Events) == 0 { return errors.New("missing event name(s)") } eventStringSet := set.NewStringSet() for _, eventName := range parsedQueue.Events { if eventStringSet.Contains(eventName.String()) { return &ErrDuplicateEventName{eventName} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 16 17:28:29 UTC 2021 - 8.4K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt
* EventListeners added by Interceptors will not see all events. */ private val enforceOrder: Boolean = true, ) : ConnectionListener() { val eventSequence: Deque<ConnectionEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableSetOf<Any>() /** The timestamp of the last taken event, used to measure elapsed time between events. */ private var lastTimestampNs: Long? = null
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 5.6K bytes - Viewed (0) -
docs/em/docs/advanced/openapi-callbacks.md
``` https://yourapi.com/invoices/?callback_url=https://www.external.org/events ``` ⏮️ 🎻 💪: ```JSON { "id": "2expen51ve", "customer": "Mr. Richie Rich", "total": "9999" } ``` ⤴️ *👆 🛠️* 🔜 🛠️ 🧾, & ☝ ⏪, 📨 ⏲ 📨 `callback_url` ( *🔢 🛠️*): ``` https://www.external.org/events/invoices/2expen51ve ``` ⏮️ 🎻 💪 ⚗ 🕳 💖: ```JSON {
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 6.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/Exchange.kt
import okio.ForwardingSink import okio.ForwardingSource import okio.Sink import okio.Source import okio.buffer /** * Transmits a single HTTP request and a response pair. This layers connection management and events * on [ExchangeCodec], which handles the actual I/O. */ class Exchange( internal val call: RealCall, internal val eventListener: EventListener, internal val finder: ExchangeFinder,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.2K bytes - Viewed (0)