findProvidersAsync method

  1. @override
Stream<AddrInfo> findProvidersAsync(
  1. CID cid,
  2. int count
)
override

Search for peers who are able to provide a given key

When count is 0, this method will return an unbounded number of results.

Implementation

@override
Stream<AddrInfo> findProvidersAsync(CID cid, int count) async* {
  // Create a limit option with the provided count
  final limitOption = limit(count);
  final options = [limitOption, ..._opts];
  final stream = await _discovery.findPeers(cidToNs(cid), options);

  await for (final peer in stream) {
    yield peer;
  }
}