getInboundGroupSessionsToUpload method

@override Future<List<StoredInboundGroupSession>> getInboundGroupSessionsToUpload()

Implementation

@override
Future<List<StoredInboundGroupSession>>
    getInboundGroupSessionsToUpload() async {
  final uploadQueue =
      await _inboundGroupSessionsUploadQueueBox.getAllValues();
  final sessionFutures = uploadQueue.entries
      .take(50)
      .map((entry) => getInboundGroupSession(entry.value, entry.key));
  final sessions = await Future.wait(sessionFutures);
  return sessions.whereType<StoredInboundGroupSession>().toList();
}