make the bufferTime public.

shogo4405 · Oct 6, 2024 · dbeec84 · dbeec84
1 parent 0e59104
commit dbeec84
Show file tree

Hide file tree

Showing 7 changed files with 25 additions and 7 deletions.
diff --git a/Examples/iOS/IngestViewController.swift b/Examples/iOS/IngestViewController.swift
@@ -302,9 +302,9 @@ extension IngestViewController: IOStreamRecorderDelegate {
     }
 
     func recorder(_ recorder: IOStreamRecorder, finishWriting writer: AVAssetWriter) {
-        PHPhotoLibrary.shared().performChanges({() -> Void in
+        PHPhotoLibrary.shared().performChanges({() in
             PHAssetChangeRequest.creationRequestForAssetFromVideo(atFileURL: writer.outputURL)
-        }, completionHandler: { _, error -> Void in
+        }, completionHandler: { _, error in
             do {
                 try FileManager.default.removeItem(at: writer.outputURL)
             } catch {

diff --git a/Examples/iOSSwiftUI/Model/ViewModel.swift b/Examples/iOSSwiftUI/Model/ViewModel.swift
@@ -241,9 +241,9 @@ extension ViewModel: IOStreamRecorderDelegate {
     }
 
     func recorder(_ recorder: IOStreamRecorder, finishWriting writer: AVAssetWriter) {
-        PHPhotoLibrary.shared().performChanges({() -> Void in
+        PHPhotoLibrary.shared().performChanges({() in
             PHAssetChangeRequest.creationRequestForAssetFromVideo(atFileURL: writer.outputURL)
-        }, completionHandler: { _, error -> Void in
+        }, completionHandler: { _, error in
             do {
                 try FileManager.default.removeItem(at: writer.outputURL)
             } catch {

diff --git a/Sources/IO/IOStream.swift b/Sources/IO/IOStream.swift
@@ -93,6 +93,16 @@ open class IOStream: NSObject {
         return mixer.videoIO.screen
     }
 
+    /// Specifies the buffer time before starting to display the stream.
+    public var bufferTime: Double {
+        get {
+            telly.bufferTime
+        }
+        set {
+            telly.bufferTime = newValue
+        }
+    }
+
     /// Specifies the adaptibe bitrate strategy.
     public var bitrateStrategy: any IOStreamBitRateStrategyConvertible = IOStreamBitRateStrategy() {
         didSet {

diff --git a/Sources/IO/IOTellyUnit.swift b/Sources/IO/IOTellyUnit.swift
@@ -10,6 +10,15 @@ protocol IOTellyUnitDelegate: AnyObject {
 final class IOTellyUnit {
     var isRunning: Atomic<Bool> = .init(false)
 
+    var bufferTime: Double {
+        get {
+            mediaLink.bufferTime
+        }
+        set {
+            mediaLink.bufferTime = newValue
+        }
+    }
+
     var audioFormat: AVAudioFormat? {
         didSet {
             delegate?.tellyUnit(self, didSetAudioFormat: audioFormat)

diff --git a/Sources/IO/MediaLink.swift b/Sources/IO/MediaLink.swift
@@ -70,7 +70,6 @@ final class MediaLink<T: MediaLinkDelegate> {
         if isBuffering {
             bufferingTime = bufferQueue?.duration.seconds ?? 0
             if bufferTime <= bufferingTime {
-                bufferTime += 0.1
                 isBuffering = false
             }
         }

diff --git a/Sources/RTMP/RTMPConnection.swift b/Sources/RTMP/RTMPConnection.swift
@@ -350,7 +350,7 @@ public class RTMPConnection {
             call("releaseStream", responder: nil, arguments: fcPublishName)
             call("FCPublish", responder: nil, arguments: fcPublishName)
         }
-        let responder = RTMPResponder(result: { data -> Void in
+        let responder = RTMPResponder(result: { data in
             guard let id = data[0] as? Double else {
                 return
             }

diff --git a/Sources/RTMP/RTMPMuxer.swift b/Sources/RTMP/RTMPMuxer.swift
@@ -94,7 +94,7 @@ final class RTMPMuxer {
             if audioFormat == nil {
                 audioFormat = message.makeAudioFormat()
             }
-            payload.withUnsafeBytes { (buffer: UnsafeRawBufferPointer) -> Void in
+            payload.withUnsafeBytes { (buffer: UnsafeRawBufferPointer) in
                 guard let baseAddress = buffer.baseAddress, let audioBuffer else {
                     return
                 }