- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 295 for eventbus (0.15 sec)
-
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/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) -
cni/pkg/install/install.go
// Watch our specific binaries, in each configured binary dir. // We may or may not be the only CNI plugin in play, and if we are not // we shouldn't fire events for binaries that are not ours. var binPaths []string for _, bindir := range in.cfg.CNIBinTargetDirs { for _, binary := range installedBinFiles.UnsortedList() {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Aug 09 21:33:51 UTC 2024 - 13.5K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/kt/WiresharkExample.kt
import okio.ByteString.Companion.toByteString /** * Logs SSL keys to a log file, allowing Wireshark to decode traffic and be examined with http2 * filter. The approach is to hook into JSSE log events for the messages between client and server * during handshake, and then take the agreed masterSecret from private fields of the session. * * Copy WireSharkKeyLoggerListener to your test code to use in development. *
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 10.7K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
// - kubernetes will (weirdly) issue a new status to the pod with no IP on termination, meaning // our check of `pod.status` will fail for (some) termination events. // // We will get subsequent events that append a new status with the IP put back, but it's simpler // and safer to just check the old pod status for the IP. err := s.dataplane.RemovePodFromMesh(s.ctx, oldPod, true)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 11.7K 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) -
tests/test_sub_callbacks.py
pass # pragma: nocover class Event(BaseModel): name: str total: float events_callback_router = APIRouter() @events_callback_router.get("{$callback_url}/events/{$request.body.title}") def event_callback(event: Event): pass # pragma: nocover subrouter = APIRouter() @subrouter.post("/invoices/", callbacks=invoices_callback_router.routes)
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Fri Jul 07 17:12:13 UTC 2023 - 13.8K bytes - Viewed (0) -
tests/test_tutorial/test_events/test_tutorial002.py
import pytest from fastapi import FastAPI from fastapi.testclient import TestClient @pytest.fixture(name="app", scope="module") def get_app(): with pytest.warns(DeprecationWarning): from docs_src.events.tutorial002 import app yield app def test_events(app: FastAPI): with TestClient(app) as client: response = client.get("/items/") assert response.status_code == 200, response.text
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Oct 18 12:36:40 UTC 2023 - 1.4K bytes - Viewed (0) -
build-logic-commons/gradle-plugin/src/main/kotlin/gradlebuild.cache-miss-monitor.gradle.kts
*/ @file:Suppress("UNCHECKED_CAST") import gradlebuild.AbstractBuildScanInfoCollectingService import gradlebuild.registerBuildScanInfoCollectingService import org.gradle.tooling.events.task.TaskOperationResult import org.gradle.tooling.events.task.TaskSuccessResult import java.io.Serializable import java.util.concurrent.atomic.AtomicBoolean /**
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Thu Mar 07 05:49:29 UTC 2024 - 4.6K bytes - Viewed (0)