Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 265 for eventbus (0.06 sec)

  1. 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)
  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. 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)
  4. 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)
  5. 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)
  6. 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)
  7. okhttp/src/test/java/okhttp3/internal/http/CancelTest.kt

        cancelLatch.await()
    
        val events = listener.eventSequence.filter { isConnectionEvent(it) }.map { it.name }
        listener.clearAllEvents()
    
        assertThat(events).startsWith("CallStart", "ConnectStart", "ConnectEnd", "ConnectionAcquired")
        if (cancelMode == CANCEL) {
          assertThat(events).contains("Canceled")
        } else {
          assertThat(events).doesNotContain("Canceled")
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Jan 20 10:30:28 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  8. 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)
  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. internal/logger/help.go

    			Description: "mTLS certificate key for webhook authentication",
    			Optional:    true,
    			Type:        "string",
    			Sensitive:   true,
    		},
    		config.HelpKV{
    			Key:         BatchSize,
    			Description: "Number of events per HTTP send to webhook target",
    			Optional:    true,
    			Type:        "number",
    		},
    		config.HelpKV{
    			Key:         QueueSize,
    			Description: "configure channel queue size for webhook targets",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 11 22:20:42 UTC 2024
    - 7.4K bytes
    - Viewed (0)
Back to top