12. Migrasi dari Combine

// Bridge Combine Publisher ke AsyncSequence
import Combine
import AsyncAlgorithms

extension Publisher where Failure == Never {
    var asyncStream: AsyncStream<Output> {
        AsyncStream { continuation in
            let cancellable = sink { completion in
                continuation.finish()
            } receiveValue: { value in
                continuation.yield(value)
            }
            continuation.onTermination = { _ in
                cancellable.cancel()
            }
        }
    }
}

extension Publisher {
    var asyncThrowingStream: AsyncThrowingStream<Output, Error> {
        AsyncThrowingStream { continuation in
            let cancellable = sink { completion in
                switch completion {
                case .finished: continuation.finish()
                case .failure(let error): continuation.finish(throwing: error)
                }
            } receiveValue: { value in
                continuation.yield(value)
            }
            continuation.onTermination = { _ in
                cancellable.cancel()
            }
        }
    }
}

// Penggunaan: Combine Publisher dipakai sebagai AsyncSequence
let publisher = NotificationCenter.default
    .publisher(for: UIApplication.didBecomeActiveNotification)

Task {
    for await _ in publisher.asyncStream {
        await refreshData()
    }
}