Returns a ServiceSnapshots, which is an AsyncSequence and each of its items is a snapshot listing of service instances.
func subscribe(to service: Service) -> ServiceSnapshots<Instance> s16ServiceDiscoveryAAPAAE9subscribe2toAA0A9SnapshotsVy8InstanceQzG0A0Qz_tF What are these?47A5QThe service to subscribe to
A ServiceSnapshots async sequence.
import ServiceDiscoveryA Service Discovery API for Swift.
@preconcurrency protocol ServiceDiscovery : AnyObject, SendableProvides service instances lookup.
@preconcurrency struct ServiceSnapshots<Instance> where Instance : SendableAn async sequence of snapshot listings of service instances.
associatedtype Service : Hashable, SendableService identity type
associatedtype Instance : Hashable, SendableService instance type
@preconcurrency func lookup(_ service: Service, deadline: DispatchTime?, callback: @escaping (Result<[Instance], Error>) -> Void) Performs a lookup for the given service’s instances. The result will be sent to callback.
@preconcurrency func subscribe(to service: Service, onNext nextResultHandler: @escaping (Result<[Instance], Error>) -> Void, onComplete completionHandler: @escaping (CompletionReason) -> Void) -> CancellationToken Subscribes to receive a service’s instances whenever they change.
func lookup(_ service: Service, deadline: DispatchTime? = nil) async throws -> [Instance] Performs async lookup for the given service’s instances.
@preconcurrency func filterInstance(_ predicate: @escaping (Instance) throws -> Bool) -> FilterInstanceServiceDiscovery<Self> Creates a new ServiceDiscovery implementation based on this one, filtering instances with the given predicate.
@preconcurrency func mapInstance<DerivedInstance>(_ transformer: @escaping (Instance) throws -> DerivedInstance) -> MapInstanceServiceDiscovery<Self, DerivedInstance> where DerivedInstance : Hashable, DerivedInstance : Sendable Creates a new ServiceDiscovery implementation based on this one, transforming the instances according to the derived function.
@preconcurrency func mapService<ComputedService>(serviceType: ComputedService.Type = ComputedService.self, _ transformer: @escaping (ComputedService) throws -> Service) -> MapServiceServiceDiscovery<Self, ComputedService> where ComputedService : Hashable, ComputedService : Sendable Creates a new ServiceDiscovery implementation based on this one, transforming the services according to the derived function.