ref: optional target for Delegate

Author: ZeroOnet

README.md

@@ -25,16 +25,24 @@ ZonPlayer is a player library base on AVPlayer with cache and remote control sup
 
 ```swift
 
-    let player: ZonPlayable = ZonPlayer.player(URLConvertible)
-        .session(ZonPlayer.Sessionable)
-        .cache(ZonPlayer.Cacheable) // Conform ZonPlayer.Cacheable to customize cache category.
+    let player: ZonPlayable = ZonPlayer.player(any URLConvertible)
+        .session(any ZonPlayer.Sessionable)
+        .cache(any ZonPlayer.Cacheable) // Conform ZonPlayer.Cacheable to customize cache category.
         .remoteControl(self) { wlf, payload in // Conform ZonPlayer.RemoteControllable to customize background playback controller.
             payload.title(String).artist(String)....
         }
         .onPaused(self) { wlf, payload in // Conform ZonPlayer.Observable to listen player.
         }
         .activate(in: ZonPlayerView)
 
+    // or
+    let player: ZonPlayable = ZonPlayer.player(any URLConvertible)
+        .on(\.session, any ZonPlayer.Sessionable)
+        .on(\.cache, any ZonPlayer.Cacheable)
+        .on(\.finish, .init {  in })
+        .on(\.pause, .init(on: self, block: { wlf, player in }))
+        .activate()
+
     // Conform ZonPlayer.Controllable to control player instance.
     player.pause()
     player.play()

Sources/Core/Private/Builder.swift

@@ -6,14 +6,12 @@
 //
 
 final class Builder: ZonPlayer.Settable, @unchecked Sendable {
-
     let url: URLConvertible & Sendable
     init(url: URLConvertible & Sendable) {
         self.url = url
     }
 
     var progressInterval: TimeInterval = 1
-    var maxRetryCount: Int = 1
 
     // MARK: - ZPObservable
     var callbackQueue: DispatchQueue = .main
@@ -22,7 +20,7 @@ final class Builder: ZonPlayer.Settable, @unchecked Sendable {
     var play: ZonPlayer.Delegate<(ZonPlayable, Float), Void>?
     var pause: ZonPlayer.Delegate<ZonPlayable, Void>?
     var finish: ZonPlayer.Delegate<(ZonPlayable, URL), Void>?
-    var error: ZonPlayer.Delegate<(ZonPlayable, ZonPlayer.Error), Void>?
+    var error: ZonPlayer.Delegate<(ZonPlayable?, ZonPlayer.Error), Void>?
     var progress: ZonPlayer.Delegate<(ZonPlayable, TimeInterval, TimeInterval), Void>?
     var duration: ZonPlayer.Delegate<(ZonPlayable, TimeInterval), Void>?
     var background: ZonPlayer.Delegate<(ZonPlayable, Bool), Void>?

Sources/Core/Private/CallbackCompositer.swift

@@ -52,7 +52,7 @@ final class CallbackCompositer: ZonPlayer.Observable, @unchecked Sendable {
         }
     }()
 
-    lazy var error: ZonPlayer.Delegate<(ZonPlayable, ZonPlayer.Error), Void>? = {
+    lazy var error: ZonPlayer.Delegate<(ZonPlayable?, ZonPlayer.Error), Void>? = {
         .init().delegate(on: self) { wlf, input in
             wlf._callback { $0.error?.call(input) }
             wlf._monitor { $0.player(input.0, playFailed: input.1) }

Sources/Core/ZonPlayer+Monitorable.swift

@@ -15,7 +15,7 @@ extension ZonPlayer {
 
         func playerPlayDidFinish(_ player: ZonPlayable, url: URL)
 
-        func player(_ player: ZonPlayable, playFailed error: ZonPlayer.Error)
+        func player(_ player: ZonPlayable?, playFailed error: ZonPlayer.Error)
 
         func player(_ player: ZonPlayable, playProgressDidChange currentTime: TimeInterval, totalTime: TimeInterval)
 
@@ -35,7 +35,7 @@ extension ZonPlayer.Monitorable {
     public func player(_ player: ZonPlayable, didPlay rate: Float) {}
     public func playerDidPause(_ player: ZonPlayable) {}
     public func playerPlayDidFinish(_ player: ZonPlayable, url: URL) {}
-    public func player(_ player: ZonPlayable, playFailed error: ZonPlayer.Error) {}
+    public func player(_ player: ZonPlayable?, playFailed error: ZonPlayer.Error) {}
     public func player(
         _ player: ZonPlayable,
         playProgressDidChange currentTime: TimeInterval,

Sources/Usage/Player/ZonPlayer+Observable.swift

@@ -14,7 +14,7 @@ extension ZonPlayer {
         var play: Delegate<(ZonPlayable, Float), Void>? { get nonmutating set }
         var pause: Delegate<ZonPlayable, Void>? { get nonmutating set }
         var finish: Delegate<(ZonPlayable, URL), Void>? { get nonmutating set }
-        var error: Delegate<(ZonPlayable, ZonPlayer.Error), Void>? { get nonmutating set }
+        var error: Delegate<(ZonPlayable?, ZonPlayer.Error), Void>? { get nonmutating set }
         var progress: Delegate<(ZonPlayable, TimeInterval, TimeInterval), Void>? { get nonmutating set }
         var duration: Delegate<(ZonPlayable, TimeInterval), Void>? { get nonmutating set }
         var background: Delegate<(ZonPlayable, Bool), Void>? { get nonmutating set }
@@ -63,7 +63,7 @@ extension ZonPlayer.Observable {
     }
 
     /// Listen to player failed because of an error.
-    public func onError<T: AnyObject>(_ target: T, block: ((T, (ZonPlayable, ZonPlayer.Error)) -> Void)?) -> Self {
+    public func onError<T: AnyObject>(_ target: T, block: ((T, (ZonPlayable?, ZonPlayer.Error)) -> Void)?) -> Self {
         error = (error ?? .init()).delegate(on: target, block: block)
         return self
     }

Sources/Usage/Player/ZonPlayer+Settable.swift

@@ -25,3 +25,11 @@ extension ZonPlayer.Settable {
         ZonPlayer.Manager.shared.start(setter: self, in: view)
     }
 }
+
+extension ZonPlayer.Settable {
+    @discardableResult
+    public func on<Value>(_ keyPath: ReferenceWritableKeyPath<Self, Value>, _ value: Value) -> Self {
+        self[keyPath: keyPath] = value
+        return self
+    }
+}

Sources/Usage/ZonPlayer+Delegate.swift

@@ -8,9 +8,22 @@
 extension ZonPlayer {
     // From https://github.com/onevcat/Kingfisher/blob/277f1ab2c6664b19b4a412e32b094b201e2d5757/Sources/Utility/Delegate.swift#L71
     public final class Delegate<Input, Output>: @unchecked Sendable {
+        public typealias Block = (Input) -> Output?
+
+        private var block: Block?
         public init() {}
 
-        private var block: ((Input) -> Output?)?
+        public init(block: @escaping Block) {
+            self.block = block
+        }
+
+        public init<T: AnyObject>(on target: T, block: @escaping (T, Input) -> Output) {
+            self.block = { [weak target] input in
+                guard let target = target else { return nil }
+                return block(target, input)
+            }
+        }
+
         @discardableResult
         public func delegate<T: AnyObject>(on target: T, block: ((T, Input) -> Output)?) -> Self {
             self.block = { [weak target] input in
@@ -20,6 +33,12 @@ extension ZonPlayer {
             return self
         }
 
+        @discardableResult
+        public func delegate(block: ((Input) -> Output)?) -> Self {
+            self.block = block
+            return self
+        }
+
         public func call(_ input: Input) -> Output? { block?(input) }
         public func callAsFunction(_ input: Input) -> Output? { call(input) }
     }

Tests/Playback/ControllerTests.swift

@@ -9,7 +9,7 @@
 final class ControllerTests: QuickSpec {
     override static func spec() {
         describe("Test player controller") {
-            it("play") {
+            it("Play") {
                 waitUntil(timeout: .seconds(5)) { done in
                     let player = ZonPlayer
                         .player(self._url)
@@ -26,7 +26,7 @@ final class ControllerTests: QuickSpec {
                 }
             }
 
-            it("pause") {
+            it("Pause") {
                 waitUntil(timeout: .seconds(5)) { done in
                     let player = ZonPlayer
                         .player(self._url)

Tests/Playback/InvalidInitializationTests.swift

@@ -10,16 +10,19 @@ final class InvalidInitializationTests: QuickSpec {
     override static func spec() {
         describe("Test player initialization") {
             it("Invalid url") {
-                waitUntil { done in
+                waitUntil(timeout: .seconds(5)) { done in
+                    var errorsCount = 2
                     let invalidURL = ""
                     let player = ZonPlayer
                         .player(invalidURL)
+                        .cache(ZPC.Streaming())
                         .onError(_delegate) { _, payload in
-                            guard case .invalidURL = payload.1 else {
-                                self.__zon_triggerUnexpectedError()
-                                return
+                            switch payload.1 {
+                            case .invalidURL, .playerTerminated:
+                                errorsCount -= 1
+                            default: return
                             }
-                            done()
+                            if errorsCount == 0 { done() }
                         }
                         .activate()
                     self._players.append(player)