func subscribeAndUnwrap()

in Sources/ServiceDiscovery/ServiceDiscovery+TypeErased.swift [202:215]

• 14 lines of code
• 3 McCabe index (conditional complexity)

    func subscribeAndUnwrap<Service, Instance>(to service: Service) -> ServiceSnapshots<Instance> where Service: Hashable, Instance: Hashable {
        ServiceSnapshots(AsyncThrowingStream { continuation in
            Task {
                do {
                    for try await snapshot in self.subscribe(to: service) {
                        continuation.yield(try snapshot.map(self.transform))
                    }
                    continuation.finish()
                } catch {
                    continuation.finish(throwing: error)
                }
            }
        })
    }