Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 295 for eventbus (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top