createDiscovery method

  1. @override
Future<IDiscovery> createDiscovery({
  1. required NetworkStreamConfig streamConfig,
  2. required CoordinationConfig coordinationConfig,
  3. required String id,
})
override

Creates a discovery instance for finding peers on this transport.

Implementation

@override
Future<IDiscovery> createDiscovery({
  required NetworkStreamConfig streamConfig,
  required CoordinationConfig coordinationConfig,
  required String id,
}) async {
  final discovery = WsDiscovery(
    connection: _connection,
    coordinationConfig: coordinationConfig,
    id: id,
  );
  await discovery.create();
  manageResource(discovery);
  return discovery;
}