inflightCount method

@override Future<int?> inflightCount(String queue)

Returns the number of in-flight messages for queue, if supported.

Implementation

@override
Future<int?> inflightCount(String queue) async => _state(queue).inflight;