Extension to create an AnyPublisher to easily 'lift' async code into Combine

AnyPublisher+Extension.swift

extension AnyPublisher where Failure: Error {
    struct Subscriber: Sendable {
        fileprivate let send: @Sendable (Output) -> Void
        fileprivate let complete: @Sendable (Subscribers.Completion<Failure>) -> Void

        func send(_ value: Output) { self.send(value) }
        func send(completion: Subscribers.Completion<Failure>) { self.complete(completion) }
    }

    init(_ closure: (Subscriber) -> AnyCancellable) {
        nonisolated(unsafe) let subject = PassthroughSubject<Output, Failure>()

        let subscriber = Subscriber(
            send: { subject.send($0) },
            complete: { subject.send(completion: $0) }
        )
        let cancel = closure(subscriber)

        self = subject
            .handleEvents(receiveCancel: cancel.cancel)
            .eraseToAnyPublisher()
    }
}