Doc coverage - 100%

Author: ikhvorost

Sources/M3U8Decoder/Atomic.swift

@@ -37,11 +37,11 @@ func synchronized<T>(_ obj: AnyObject, closure: () -> T) -> T {
 class Atomic<T>: @unchecked Sendable {
   var _value: T
 
-  public init(_ value: T) {
+  init(_ value: T) {
     _value = value
   }
 
-  public var value: T {
+  var value: T {
     get {
       synchronized(self) { _value }
     }

Tests/M3U8DecoderTests/M3U8DecoderTests.swift

@@ -1,10 +1,45 @@
 import XCTest
 import Combine
 
-@testable
 import M3U8Decoder
 
 
+class SendableArray<T>: @unchecked Sendable {
+  private var array: [T]
+  
+  private func sync<U>(closure: () -> U) -> U {
+    objc_sync_enter(self)
+    defer {
+      objc_sync_exit(self)
+    }
+    return closure()
+  }
+  
+  init(_ array: [T]) {
+    self.array = array
+  }
+  
+  subscript(i: Int) -> T {
+    get {
+      sync { array[i] }
+    }
+    set {
+      sync { array[i] = newValue }
+    }
+  }
+  
+  var count: Int {
+    sync { array.count }
+  }
+  
+  func forEach(body: (T) -> Void) {
+    sync {
+      array.forEach(body)
+    }
+  }
+}
+
+
 final class M3U8_All: XCTestCase {
 
   func test_error_empty() {
@@ -575,12 +610,12 @@ final class M3U8_All: XCTestCase {
 
     let decoder = M3U8Decoder()
 
-    let playlists = AtomicArray<Playlist?>(repeating: nil, count: 10)
+    let playlists = SendableArray([Playlist?](repeating: nil, count: 10))
     DispatchQueue.concurrentPerform(iterations: playlists.count) {
       playlists[$0] = try? decoder.decode(Playlist.self, from: text)
     }
 
-    playlists.value.forEach {
+    playlists.forEach {
       XCTAssert($0?.ext_x_targetduration == 10)
       XCTAssert($0?.segments.count == 3)
       XCTAssert($0?.segments[0].extinf.duration == 9.009)