streamHandlingExceptions

inline fun <T> streamHandlingExceptions(block: () -> Flow<HubPayload<T>>): Flow<HubPayload<T>>