pullFromDiskQueue method

Future<OutgoingMessage?> pullFromDiskQueue(
  1. int i
)

Implementation

Future<OutgoingMessage?> pullFromDiskQueue(int i) async {
  if (_data[i] != null) return _data[i]!;
  final pd = await _io?.readUint8List(_ioSiteName + 'ogmDq' + i.toString());
  if (pd != null && pd.isNotEmpty) {
    try {
      final ie = OutgoingMessage.fromBinary(pd);
      _data[i] = ie;
      return ie;
    } catch (e) {
      print('pullFromDiskQueue item exploded');
      _io?.deleteUint8List(_ioSiteName + 'ogmDq' + i.toString());
    }
  }
  return null;
}