Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 295 for eventbus (0.13 sec)

  1. common-protos/k8s.io/api/events/v1/generated.proto

    // Events have a limited retention time and triggers and messages may evolve
    // with time.  Event consumers should not rely on the timing of an event
    // with a given Reason reflecting a consistent underlying trigger, or the
    // continued existence of events with that Reason.  Events should be
    // treated as informative, best-effort, supplemental data.
    message Event {
      // Standard object's metadata.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt

    class EventSourceRecorder : EventSourceListener() {
      private val events = LinkedBlockingDeque<Any>()
      private var cancel = false
    
      fun enqueueCancel() {
        cancel = true
      }
    
      override fun onOpen(
        eventSource: EventSource,
        response: Response,
      ) {
        get().log("[ES] onOpen", Platform.INFO, null)
        events.add(Open(eventSource, response))
        drainCancelQueue(eventSource)
      }
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/EventListener.kt

     * request body start and end events occur within the response header events. Similarly,
     * [duplex calls][RequestBody.isDuplex] interleave the request and response bodies.
     *
     * Since connections may be reused, the proxy selection, DNS, and connect events may not be present
     * for a call. In future releases of OkHttp these events may also occur concurrently to permit
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  4. internal/bucket/lifecycle/lifecycle.go

    						// This is a MinIO only extension.
    						event.Action = DeleteAllVersionsAction
    					}
    					events = append(events, event)
    				}
    			}
    
    			if obj.TransitionStatus != TransitionComplete {
    				if due, ok := rule.Transition.NextDue(obj); ok && (now.IsZero() || now.After(due)) {
    					events = append(events, Event{
    						Action:       TransitionAction,
    						RuleID:       rule.ID,
    						Due:          due,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu May 23 01:12:48 UTC 2024
    - 17.9K bytes
    - Viewed (0)
  5. common-protos/k8s.io/api/events/v1beta1/generated.proto

    // Events have a limited retention time and triggers and messages may evolve
    // with time.  Event consumers should not rely on the timing of an event
    // with a given Reason reflecting a consistent underlying trigger, or the
    // continued existence of events with that Reason.  Events should be
    // treated as informative, best-effort, supplemental data.
    message Event {
      // Standard object's metadata.
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  6. mkdocs.yml

            # Redirect all feature pages to features/*
            'caching.md': 'features/caching.md'
            'calls.md': 'features/calls.md'
            'connections.md': 'features/connections.md'
            'events.md': 'features/events.md'
            'https.md': 'features/events.md'
            'interceptors.md': 'features/interceptors.md'
            'r8_proguard.md': 'features/r8_proguard.md'
            # Redirect all Security pages to security/*
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Nov 20 15:26:12 UTC 2023
    - 3.8K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/ListenerCallQueue.java

     * #enqueue enqueueing} and then {@linkplain #dispatch dispatching} events.
     *
     * <p>The API of this class is designed to make it easy to achieve the following properties
     *
     * <ul>
     *   <li>Multiple events for the same listener are never dispatched concurrently.
     *   <li>Events for the different listeners are dispatched concurrently.
     *   <li>All events for a given listener dispatch on the provided {@link #executor}.
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Dec 13 19:45:20 UTC 2023
    - 8.2K bytes
    - Viewed (0)
  8. api/maven-api-core/src/main/java/org/apache/maven/api/Listener.java

    import org.apache.maven.api.annotations.Consumer;
    import org.apache.maven.api.annotations.Experimental;
    import org.apache.maven.api.annotations.Nonnull;
    
    /**
     * A listener for session events.
     * TODO: open this to other events like similar to {@code org.apache.maven.eventspy.EventSpy}
     *
     * @since 4.0.0
     */
    @Experimental
    @FunctionalInterface
    @Consumer
    public interface Listener {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Thu Mar 23 05:29:39 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  9. okhttp-sse/README.md

    OkHttp Server-Sent Events
    =========================
    
    Experimental support for server-sent events.
    API is not considered stable and may change at any time.
    
    ### Download
    
    ```kotlin
    testImplementation("com.squareup.okhttp3:okhttp-sse:4.12.0")
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Dec 17 15:34:10 UTC 2023
    - 245 bytes
    - Viewed (0)
  10. docs/pt/docs/advanced/async-tests.md

    /// tip | "Dica"
    
    Note que nós estamos utilizando async/await com o novo `AsyncClient` - a requisição é assíncrona.
    
    ///
    
    /// warning | "Aviso"
    
    Se a sua aplicação depende dos eventos de vida útil (*lifespan*), o `AsyncClient` não acionará estes eventos. Para garantir que eles são acionados, utilize o `LifespanManager` do <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 06 20:36:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
Back to top