redis_streams:xidle

xidle_group(+Redis, +Streams, +Starts, +NewStarts, +Options) is det[private]

Called after XREADGROUP returns and the returned messages (if any) have been processed. If Start == NewStarts no messages have been processed, indicating a timeout.

This implementation looks for idle messages on other consumer and will try to claim them.

To be done: - : max time to work on other consumers messages?