`AsyncStream` periodicTimeValues for AVPlayer

AVPlayer+Ext.swift

import Foundation
import AVFoundation

public extension AVPlayer {
    func periodicTimeValues(
        forInterval interval: CMTime,
        queue: dispatch_queue_t? = nil
    ) -> AsyncStream<TimeInterval> {

        let (stream, continuation) = AsyncStream.makeStream(of: Double.self)

        nonisolated(unsafe) var timeObserver: Any? = self.addPeriodicTimeObserver(forInterval: interval, queue: queue) { time in
            let seconds = time.seconds
            if !seconds.isNaN && seconds.isFinite {
                continuation.yield(seconds)
            }
        }

        continuation.onTermination = { _ in
            if let observer = timeObserver {
                self.removeTimeObserver(observer)
                timeObserver = nil
            }

        }

        return stream
    }
}