@override Future<IShspInstance?> getShsp(PeerInfo remotePeer) async { // Wait for any ongoing operations await _lock.future; final instance = _instances[remotePeer]; return instance; }