countActiveFlow

fun countActiveFlow(): Flow<Long>

Reactive queue depth: emits on every DB change that affects the non-SENT count.

Since

1.2.0