subscribeSafelyAsync

fun <T, M> Flow<T>.subscribeSafelyAsync(    scope: CoroutineScope,     markerFactory: suspend (T) -> M,     onException: ExceptionHandler<Unit> = defaultSafelyExceptionHandler,     block: suspend (T) -> Unit): Job(source)