- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 224 for Events (0.04 sec)
-
docs/en/docs/advanced/events.md
In this case, the `startup` event handler function will initialize the items "database" (just a `dict`) with some values. You can add more than one event handler function. And your application won't start receiving requests until all the `startup` event handlers have completed. ### `shutdown` event { #shutdown-event } To add a function that should be run when the application is shutting down, declare it with the event `"shutdown"`:
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 7.9K bytes - Viewed (0) -
docs/en/docs/advanced/testing-events.md
# Testing Events: lifespan and startup - shutdown { #testing-events-lifespan-and-startup-shutdown } When you need `lifespan` to run in your tests, you can use the `TestClient` with a `with` statement: {* ../../docs_src/app_testing/tutorial004.py hl[9:15,18,27:28,30:32,41:43] *} You can read more details about the ["Running lifespan in tests in the official Starlette documentation site."](https://www.starlette.io/lifespan/#running-lifespan-in-tests)
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 10:29:21 UTC 2025 - 615 bytes - Viewed (0) -
docs/ko/docs/advanced/events.md
{* ../../docs_src/events/tutorial003.py hl[14:19] *} 함수의 첫 번째 부분, 즉 `yield` 이전의 코드는 애플리케이션이 시작되기 **전에** 실행됩니다. 그리고 `yield` 이후의 부분은 애플리케이션이 완료된 후 **나중에** 실행됩니다. ### 비동기 컨텍스트 매니저 함수를 확인해보면, `@asynccontextmanager`로 장식되어 있습니다. 이것은 함수를 "**비동기 컨텍스트 매니저**"라고 불리는 것으로 변환시킵니다. {* ../../docs_src/events/tutorial003.py hl[1,13] *}
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Fri May 30 13:33:53 UTC 2025 - 9.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/eventbus/EventBusTest.java
} public void testDeadEventPosting() { GhostCatcher catcher = new GhostCatcher(); bus.register(catcher); bus.post(new DeadEvent(this, EVENT)); List<DeadEvent> events = catcher.getEvents(); assertEquals("The explicit DeadEvent should be delivered.", 1, events.size()); assertEquals("The dead event must not be re-wrapped.", EVENT, events.get(0).getEvent());
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 11.3K bytes - Viewed (0) -
docs/bucket/notifications/README.md
<database>"` MinIO supports persistent event store. The persistent store will backup events if MySQL connection goes offline and then replays the stored events when the broken connection comes back up. The event store can be configured by setting a directory path in `queue_dir` field, and the maximum number of events, which can be stored in a `queue_dir`, in `queue_limit` field. For example, `queue_dir` can be set to `/home/events` and `queue_limit` can be set to `1000`. By default,...
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 84.2K bytes - Viewed (0) -
okhttp-sse/src/test/java/okhttp3/sse/internal/EventSourceRecorder.kt
fun assertExhausted() { assertThat(events).isEmpty() } fun assertEvent( id: String?, type: String?, data: String, ) { assertThat(nextEvent()).isEqualTo(Event(id, type, data)) } fun assertOpen(): EventSource { val event = nextEvent() as Open return event.eventSource } fun assertClose() { nextEvent() as Closed } fun assertFailure(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Aug 30 11:32:52 UTC 2025 - 3.2K bytes - Viewed (0) -
android/guava/src/com/google/common/eventbus/Dispatcher.java
} }; @Override void dispatch(Object event, Iterator<Subscriber> subscribers) { checkNotNull(event); checkNotNull(subscribers); // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get Queue<Event> queueForThread = requireNonNull(queue.get()); queueForThread.offer(new Event(event, subscribers)); if (!dispatching.get()) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 7.4K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/EventListener.kt
import java.net.Proxy /** * Listener for metrics events. Extend this class to monitor the quantity, size, and duration of * your application's HTTP calls. * * All start/connect/acquire events will eventually receive a matching end/release event, either * successful (non-null parameters), or failed (non-null throwable). The first common parameters of * each event pair are used to link the event in case of concurrent or repeated events e.g.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue May 27 14:58:02 UTC 2025 - 17.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
} /** * Enqueues an event to be run on currently known listeners. * * <p>The {@code toString} method of the Event itself will be used to describe the event in the * case of an error. * * @param event the callback to execute on {@link #dispatch} */ public void enqueue(Event<L> event) { enqueueHelper(event, event); } /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.1K bytes - Viewed (0) -
guava-tests/test/com/google/common/eventbus/StringCatcher.java
public class StringCatcher { private final List<String> events = new ArrayList<>(); @Subscribe public void hereHaveAString(@Nullable String string) { events.add(string); } public void methodWithoutAnnotation(@Nullable String string) { Assert.fail("Event bus must not call methods without @Subscribe!"); } public List<String> getEvents() { return events; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 1.4K bytes - Viewed (0)