agents-core/ai.koog.agents.core.feature.writer/FeatureMessageFileWriter

FeatureMessageFileWriter

abstract class FeatureMessageFileWriter<Path>(val targetPath: Path, sinkOpener: (Path) -> Sink) : FeatureMessageProcessor(source)

A feature message processor responsible for writing feature messages to a file. This abstract class provides functionality to convert and write feature messages into a target file using a specified file system provider.

Parameters

Path

The type representing paths supported by the file system provider.

targetPath

The file where feature messages will be written.

sinkOpener

Returns a Sink for writing to the file, this class manages its lifecycle.

Constructors

FeatureMessageFileWriter

constructor(targetPath: Path, sinkOpener: (Path) -> Sink)

Properties

isOpen

open override val isOpen: StateFlow<Boolean>

Indicates whether the writer is currently open and ready for operation.

messageFilter

val messageFilter: (FeatureMessage) -> Boolean

A filter for messages to be sent to message processors.

targetPath

val targetPath: Path

Functions

open suspend override fun close()

initialize

open suspend override fun initialize()

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

onMessage

suspend fun onMessage(message: FeatureMessage)

Receives and processes an incoming feature message.

setMessageFilter

fun setMessageFilter(filter: (FeatureMessage) -> Boolean)

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

toFileString

abstract fun FeatureMessage.toFileString(): String

Converts the FeatureMessage instance to its corresponding string representation suitable for writing to a file.