A2uiMessageProcessor

suspend fun collectMessages(): Unit

Suspends and continuously processes all incoming messages queued by processMessage.

This method acts as the engine's main processing loop. It should be launched within a coroutine scope tied to the host application's lifecycle (such as a ViewModel). If this method is not running, any messages passed to processMessage will remain queued.

When the calling coroutine scope is cancelled, the processing loop will gracefully terminate.

fun processError(error: A2uiClientErrorMessage): Unit

Enqueues a client error message to be transmitted back to the server via outboundEvents.

fun processMessage(message: A2uiServerToClientMessage): Unit

Enqueues a parsed protocol message to be processed.

Note that this method does not execute the processing itself. Messages are queued and will only be handled while collectMessages is actively running.

This method is thread-safe and can be called from any thread.

val activeSurfaces: StateFlow<List<A2uiSurfaceModel>>

A flow of the active surface models currently managed by the processor.

val outboundEvents: Flow<A2uiClientToServerMessage>

A flow of user actions and error payloads to be transmitted to the server.

fun <T : Any?> A2uiMessageProcessor.processInput(
    parser: A2uiMessageParser<T>,
    input: T
): Unit

Parses input using parser and enqueues the resulting message into this processor.

If parsing fails with an A2uiException (such as A2uiException.A2uiValidationException), the exception is caught, converted into an A2uiClientErrorMessage, and sent to processError. Unexpected runtime exceptions are not caught.