readMessageCount method

@override Future<int> readMessageCount()

Reads the current number of messages in the queue to be delivered.

Returns Future that receives number of messages Throws error.

Implementation

@override
Future<int> readMessageCount() async {
  // Subscribe to get messages
  return _messages.length;
}