A service discovery implementation that maps services using a closure.
final class MapServiceServiceDiscovery<BaseDiscovery, ComputedService> where BaseDiscovery : ServiceDiscovery, ComputedService : Hashable, ComputedService : Sendableimport ServiceDiscoveryA Service Discovery API for Swift.
@preconcurrency protocol ServiceDiscovery : AnyObject, SendableProvides service instances lookup.
protocol Hashable : EquatableA type that can be hashed into a Hasher to produce an integer hash value.
protocol Sendableprotocol CopyableA type whose values can be implicitly or explicitly copied.
protocol Escapablevar defaultLookupTimeout: DispatchTimeInterval { get }@preconcurrency func lookup(_ service: ComputedService, deadline: DispatchTime?, callback: @escaping (Result<[BaseDiscovery.Instance], Error>) -> Void) @preconcurrency func subscribe(to service: ComputedService, onNext nextResultHandler: @escaping (Result<[BaseDiscovery.Instance], Error>) -> Void, onComplete completionHandler: @escaping (CompletionReason) -> Void) -> CancellationToken @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.
func lookup(_ service: Service, deadline: DispatchTime? = nil) async throws -> [Instance] Performs async lookup for the given service’s instances.
@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.
func subscribe(to service: Service) -> ServiceSnapshots<Instance> Returns a ServiceSnapshots, which is an AsyncSequence and each of its items is a snapshot listing of service instances.