Stream<Peer> get discoveryEvents { throw UnimplementedError('discoveryEvents has not been implemented.'); }