agents-core/ai.koog.agents.core.feature.message/FeatureMessageProcessor

FeatureMessageProcessor

abstract class FeatureMessageProcessor : Closeable(source)

Represents a provider responsible for handling outbound feature messages or events.

Feature processors are used to encapsulate feature-related logic and provide a common interface for handling feature messages and events, such as

  • node started

  • node finished

  • strategy started, etc.

Implementations of this interface are designed to process feature messages, which are encapsulated in the FeatureMessage type and presented as a model for an event to be sent to a target stream. These messages carry information about various events or updates related to features in the system.

Inheritors

Constructors

Link copied to clipboard
constructor()

Properties

Link copied to clipboard
abstract val isOpen: StateFlow<Boolean>

A StateFlow representing the current open state of the processor.

Link copied to clipboard
val messageFilter: (FeatureMessage) -> Boolean

A filter for messages to be sent to message processors.

Functions

Link copied to clipboard
abstract suspend fun close()
Link copied to clipboard
open suspend fun initialize()

Initializes the feature output stream provider to ensure it is ready for use.

Link copied to clipboard
suspend fun onMessage(message: FeatureMessage)

Receives and processes an incoming feature message.

Link copied to clipboard
fun setMessageFilter(filter: (FeatureMessage) -> Boolean)

Sets the message filter used to determine which feature messages should be processed.