subscribeSafely

inline fun <T> Flow<T>.subscribeSafely(scope: CoroutineScope, noinline onException: ExceptionHandler<Unit> = defaultSafelyExceptionHandler, noinline block: suspend (T) -> Unit): Job(source)

Use subscribe, but all blocks will be called inside of safely function. Use onException to set up your reaction for Throwables