safeOnNextError

open fun safeOnNextError(value: T, throwable: Throwable)

Handles errors that occur during message processing.

Called when safeOnNext throws an exception.

Parameters

value

The message value that caused the error

throwable

The exception that was thrown