if e.lockRetention != nil && e.lockRetention.LockEnabled {
				event = Event{}
			} else {
				// No need to evaluate remaining versions' lifecycle
				// events after DeleteAllVersionsAction*
				events[i] = event
				break loop
			}

		case DeleteVersionAction, DeleteRestoredVersionAction:
			// Defensive code, should never happen
			if obj.VersionID == "" {

/// tip | Consejo

Nota que estamos usando async/await con el nuevo `AsyncClient`: el request es asíncrono.

///

/// warning | Advertencia

Si tu aplicación depende de eventos de lifespan, el `AsyncClient` no activará estos eventos. Para asegurarte de que se activen, usa `LifespanManager` de [florimondmanca/asgi-lifespan](https://github.com/florimondmanca/asgi-lifespan#usage).

///

        Map<EventType, Long> statsBefore = logger.getStatistics();
        assertTrue(statsBefore.get(EventType.AUTHENTICATION_SUCCESS) > 0, "Should have authentication events before reset");
        assertTrue(statsBefore.get(EventType.FILE_ACCESS) > 0, "Should have file access events before reset");

        logger.resetStatistics();

        Map<EventType, Long> statsAfter = logger.getStatistics();

```python
@app.get("/items/stream")
async def stream_items() -> AsyncIterable[Item]:
    for item in items:
        yield item
```

## Server-Sent Events (SSE)

To stream Server-Sent Events, use `response_class=EventSourceResponse` and `yield` items from the endpoint.

Plain objects are automatically JSON-serialized as `data:` fields, declare the return type so the serialization is done by Pydantic:

        // Verify all values are unique
        for (int i = 0; i < events.length; i++) {
            for (int j = i + 1; j < events.length; j++) {
                assertNotEquals(events[i].getValue(), events[j].getValue(),
                        "Event types " + events[i] + " and " + events[j] + " have the same value");
            }
        }
    }

    @Test

/// tip | Dica

Note que nós estamos utilizando async/await com o novo `AsyncClient` - a requisição é assíncrona.

///

/// warning | Atenção

Se a sua aplicação depende de eventos de lifespan, o `AsyncClient` não acionará estes eventos. Para garantir que eles são acionados, utilize o `LifespanManager` do [florimondmanca/asgi-lifespan](https://github.com/florimondmanca/asgi-lifespan#usage).

///

 * 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

   * EventListeners added by Interceptors will not see all events.
   */
  private val enforceOrder: Boolean = true,
) {
  private val eventListenerAdapter =
    EventListenerAdapter()
      .apply {
        listeners += ::logEvent
      }

  val eventListener: EventListener
    get() = eventListenerAdapter

  /** Events that haven't yet been removed. */

			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",

		if gotEvents[i].Action != wantEvents[i].Action {
			t.Fatalf("test-%d: got %v, want %v", i+1, gotEvents[i], wantEvents[i])
		}
	}

	// Test with zero versions
	events, err := evaluator.Eval(nil)
	if len(events) != 0 || err != nil {
		t.Fatal("expected no events nor error")
	}
}

func TestEmptyEvaluator(t *testing.T) {
	var objs []ObjectOpts
	curModTime := time.Date(2025, time.February, 10, 23, 0, 0, 0, time.UTC)