Search Options

Results per page
Sort
Preferred Languages
Advance

Results 91 - 100 of 272 for eventbus (0.1 sec)

  1. 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)
  2. 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)
  3. 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"
    }
    ```
    
    ⤴️ *👆 🛠️* 🔜 🛠️ 🧾, &amp; ☝ ⏪, 📨 ⏲ 📨 `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)
  4. docs/de/docs/advanced/async-tests.md

    /// tip | "Tipp"
    
    Beachten Sie, dass wir async/await mit dem neuen `AsyncClient` verwenden – der Request ist asynchron.
    
    ///
    
    /// warning | "Achtung"
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 27 15:34:47 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top