Future<Map<String, dynamic>?> getAll(PeerId peerId) async { return _lock.synchronized(() { return _ds[peerId.toString()]; }); }