Combine to async

CombineToAsync.swift

extension Publisher {
    func awaitOutput() async throws -> Output {
        return try await withCheckedThrowingContinuation { continuation in
                    let lock = NSRecursiveLock()
            var nillableContinuation: CheckedContinuation<Self.Output, Error>? = continuation
            
            var cancelable: AnyCancellable?
            cancelable = first().sink(receiveCompletion: {
                lock.lock(); defer { lock.unlock() }
                switch $0 {
                case .failure(let error):
                    nillableContinuation?.resume(throwing: error)
                default: break
                }
                nillableContinuation = nil
                cancelable?.cancel()
            }, receiveValue: {
                lock.lock(); defer { lock.unlock() }
                nillableContinuation?.resume(returning: $0)
            })
        }
    }
}