- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 272 for eventbus (0.2 sec)
-
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) -
docs/de/docs/advanced/async-tests.md
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 27 15:34:47 UTC 2024 - 4.3K bytes - Viewed (0) -
docs/en/docs/advanced/async-tests.md
/// tip Note that we're using async/await with the new `AsyncClient` - the request is asynchronous. /// /// warning If your application relies on lifespan events, the `AsyncClient` won't trigger these events. To ensure they are triggered, use `LifespanManager` from <a href="https://github.com/florimondmanca/asgi-lifespan#usage" class="external-link" target="_blank">florimondmanca/asgi-lifespan</a>. ///
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 27 15:43:29 UTC 2024 - 3.8K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/TransferListenerAdapter.java
import org.apache.maven.repository.ArtifactTransferEvent; import org.apache.maven.repository.ArtifactTransferListener; import org.apache.maven.repository.ArtifactTransferResource; import org.apache.maven.wagon.events.TransferEvent; import org.apache.maven.wagon.events.TransferListener; import org.apache.maven.wagon.repository.Repository; import org.apache.maven.wagon.resource.Resource; /** * TransferListenerAdapter */ @Deprecated
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 5K 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) -
okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt
* EventListeners added by Interceptors will not see all events. */ private val enforceOrder: Boolean = true, ) : EventListener() { val eventSequence: Deque<CallEvent> = ConcurrentLinkedDeque() private val forbiddenLocks = mutableListOf<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 - 9K bytes - Viewed (0) -
docs/en/docs/advanced/openapi-callbacks.md
https://yourapi.com/invoices/?callback_url=https://www.external.org/events ``` with a JSON body of: ```JSON { "id": "2expen51ve", "customer": "Mr. Richie Rich", "total": "9999" } ``` then *your API* will process the invoice, and at some point later, send a callback request to the `callback_url` (the *external 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 - 7.7K bytes - Viewed (0) -
docs/pt/docs/advanced/openapi-callbacks.md
https://yourapi.com/invoices/?callback_url=https://www.external.org/events ``` com um corpo JSON de: ```JSON { "id": "2expen51ve", "customer": "Mr. Richie Rich", "total": "9999" } ``` então *sua API* processará a fatura e, em algum momento posterior, enviará uma solicitação de callback para o `callback_url` (a *API externa*): ``` https://www.external.org/events/invoices/2expen51ve ```
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Oct 30 19:53:03 UTC 2024 - 8.2K bytes - Viewed (0)