Uses of Interface
org.a2aproject.sdk.server.events.TaskStreamLifecycleHook

Packages that use TaskStreamLifecycleHook

Package	Description
org.a2aproject.sdk.examples.streamlifecycle.server
org.a2aproject.sdk.extras.queuemanager.replicated.core
org.a2aproject.sdk.server.events

Uses of TaskStreamLifecycleHook in org.a2aproject.sdk.examples.streamlifecycle.server

Classes in org.a2aproject.sdk.examples.streamlifecycle.server that implement TaskStreamLifecycleHook

Modifier and Type	Class	Description
class	CloseStreamsHook	Demonstrates closing all streams for a task when the subscriber count reaches a threshold.

Uses of TaskStreamLifecycleHook in org.a2aproject.sdk.extras.queuemanager.replicated.core

Constructors in org.a2aproject.sdk.extras.queuemanager.replicated.core with parameters of type TaskStreamLifecycleHook

Modifier	Constructor	Description
	ReplicatedQueueManager(ReplicationStrategy replicationStrategy, TaskStateProvider taskStateProvider, MainEventBus mainEventBus, TaskStreamLifecycleHook streamLifecycleHook)

Uses of TaskStreamLifecycleHook in org.a2aproject.sdk.server.events

Classes in org.a2aproject.sdk.server.events that implement TaskStreamLifecycleHook

Modifier and Type	Class	Description
class	DefaultTaskStreamLifecycleHook	Default no-op implementation of TaskStreamLifecycleHook.

Methods in org.a2aproject.sdk.server.events with parameters of type TaskStreamLifecycleHook

Modifier and Type	Method	Description
EventQueue.EventQueueBuilder	EventQueue.EventQueueBuilder.streamLifecycleHook(@Nullable TaskStreamLifecycleHook streamLifecycleHook)	Sets the stream lifecycle hook for subscribe/unsubscribe/event notifications.

Constructors in org.a2aproject.sdk.server.events with parameters of type TaskStreamLifecycleHook

Modifier	Constructor	Description
	InMemoryQueueManager(EventQueueFactory factory, TaskStateProvider taskStateProvider, MainEventBus mainEventBus, TaskStreamLifecycleHook streamLifecycleHook)
	InMemoryQueueManager(TaskStateProvider taskStateProvider, MainEventBus mainEventBus, TaskStreamLifecycleHook streamLifecycleHook)