A2uiMessageProcessor

abstract void collectMessages()

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.

abstract @NonNull StateFlow<@NonNull List<@NonNull A2uiSurfaceModel>> getActiveSurfaces()

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

abstract @NonNull Flow<@NonNull A2uiClientToServerMessage> getOutboundEvents()

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

abstract void processError(@NonNull A2uiClientErrorMessage error)

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

abstract void processMessage(@NonNull A2uiServerToClientMessage message)

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.

default final void <T extends Object> A2uiMessageProcessorKt.processInput(
    @NonNull A2uiMessageProcessor receiver,
    @NonNull A2uiMessageParser<@NonNull T> parser,
    @NonNull T input
)

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.