safeOnNext

open fun safeOnNext(value: T)

Safely processes the next message.

Override this method to handle messages. Any exceptions thrown will be caught and handled by safeOnNextError.

Parameters

value

The message value to process