getShspSafe method

  1. @override
Future<IShspInstance> getShspSafe(
  1. PeerInfo remotePeer
)

Implementation

@override
Future<IShspInstance> getShspSafe(PeerInfo remotePeer) async {
  final instance = await getShsp(remotePeer);
  if (instance == null) {
    throw ShspInstanceException(
      'No SHSP instance found for peer',
      instanceId: '${remotePeer.address.address}:${remotePeer.port}',
    );
  }
  return instance;
}