Implementation of Volume Control.

SRTHaishinKit/SRTStream.swift

@@ -110,6 +110,16 @@ public actor SRTStream {
 
 extension SRTStream: HKStream {
     // MARK: HKStream
+    public var soundTransform: SoundTransform? {
+        get async {
+            await player.soundTransfrom
+        }
+    }
+
+    public func setSoundTransform(_ soundTransform: SoundTransform) async {
+        await player.setSoundTransform(soundTransform)
+    }
+
     public var audioSettings: AudioCodecSettings {
         ingestor.audioSettings
     }
@@ -158,10 +168,8 @@ extension SRTStream: HKStream {
         }
     }
 
-    public func attachAudioPlayer(_ audioPlayer: AudioPlayer?) {
-        Task {
-            await player.attachAudioPlayer(audioPlayer)
-        }
+    public func attachAudioPlayer(_ audioPlayer: AudioPlayer?) async {
+        await player.attachAudioPlayer(audioPlayer)
     }
 
     public func addOutput(_ observer: some HKStreamOutput) {

Sources/HKStream/AudioPlayerNode.swift

@@ -15,6 +15,7 @@ final actor AudioPlayerNode {
         }
         return 0.0
     }
+    private(set) var soundTransfrom = SoundTransform()
     private(set) var isPaused = false
     private let playerNode: AVAudioPlayerNode
     private var audioTime = AudioTime()
@@ -37,6 +38,10 @@ final actor AudioPlayerNode {
         self.playerNode = playerNode
     }
 
+    func setSoundTransfrom(_ soundTransfrom: SoundTransform) {
+        soundTransfrom.apply(playerNode)
+    }
+
     func enqueue(_ audioBuffer: AVAudioBuffer, when: AVAudioTime) async {
         format = audioBuffer.format
         guard let audioBuffer = audioBuffer as? AVAudioPCMBuffer, await player?.isConnected(self) == true else {

Sources/HKStream/HKStream.swift

@@ -7,10 +7,10 @@ import CoreMedia
 public protocol HKStream: Actor, MediaMixerOutput {
     /// The current state of the stream.
     var readyState: HKStreamReadyState { get }
-
+    /// The sound transform value control.
+    var soundTransform: SoundTransform? { get async }
     /// The audio compression properties.
     var audioSettings: AudioCodecSettings { get }
-
     /// The video compression properties.
     var videoSettings: VideoCodecSettings { get }
 
@@ -23,6 +23,9 @@ public protocol HKStream: Actor, MediaMixerOutput {
     /// Sets the video compression properties.
     func setVideoSettings(_ videoSettings: VideoCodecSettings)
 
+    /// Sets the sound transform value control.
+    func setSoundTransform(_ soundTransfrom: SoundTransform) async
+
     /// Appends a CMSampleBuffer.
     /// - Parameters:
     ///   - sampleBuffer:The sample buffer to append.
@@ -34,15 +37,15 @@ public protocol HKStream: Actor, MediaMixerOutput {
     ///   - when: The audio time to append.
     func append(_ audioBuffer: AVAudioBuffer, when: AVAudioTime)
 
+    /// Attaches an audio player instance for playback.
+    func attachAudioPlayer(_ audioPlayer: AudioPlayer?) async
+
     /// Adds an output observer.
     func addOutput(_ obserber: some HKStreamOutput)
 
     /// Removes an output observer.
     func removeOutput(_ observer: some HKStreamOutput)
 
-    /// Attaches an audio player instance for playback.
-    func attachAudioPlayer(_ audioPlayer: AudioPlayer?)
-
     /// Dispatch a network monitor event.
     func dispatch(_ event: NetworkMonitorEvent) async
 }

Sources/HKStream/HKStreamPlayer.swift

@@ -4,6 +4,12 @@ import Foundation
 /// An actor that provides a stream playback feature.
 public final actor HKStreamPlayer {
     public private(set) var isRunning = false
+    /// The sound transform value control.
+    public var soundTransfrom: SoundTransform? {
+        get async {
+            return await audioPlayerNode?.soundTransfrom
+        }
+    }
     private lazy var mediaLink = MediaLink()
     private lazy var audioCodec = AudioCodec()
     private lazy var videoCodec = VideoCodec()
@@ -15,6 +21,11 @@ public final actor HKStreamPlayer {
         self.stream = stream
     }
 
+    /// Sets the sound transform value control.
+    public func setSoundTransform(_ soundTransfrom: SoundTransform) async {
+        await audioPlayerNode?.setSoundTransfrom(soundTransfrom)
+    }
+
     /// Appends a sample buffer for playback.
     public func append(_ buffer: CMSampleBuffer) {
         switch buffer.formatDescription?.mediaType {
@@ -33,11 +44,9 @@ public final actor HKStreamPlayer {
     }
 
     /// Attaches an audio player.
-    public func attachAudioPlayer(_ audioPlayer: AudioPlayer?) {
-        Task {
-            audioPlayerNode = await audioPlayer?.makePlayerNode()
-            await mediaLink.setAudioPlayer(audioPlayerNode)
-        }
+    public func attachAudioPlayer(_ audioPlayer: AudioPlayer?) async {
+        audioPlayerNode = await audioPlayer?.makePlayerNode()
+        await mediaLink.setAudioPlayer(audioPlayerNode)
     }
 }
 

Sources/HKStream/SoundTransform.swift

@@ -1,16 +1,24 @@
 import AVFoundation
 import Foundation
 
-/// The SoundTransform class
-public struct SoundTransform {
+/// A structure represents the volume value controller.
+public struct SoundTransform: Equatable, Sendable {
+    /// The default volume.
     public static let defaultVolume: Float = 1.0
+    /// The default panning of the sound.
     public static let defaultPan: Float = 0
 
     /// The volume, ranging from 0 (silent) to 1 (full volume)
     public var volume = SoundTransform.defaultVolume
     /// The panning of the sound
     public var pan = SoundTransform.defaultPan
 
+    /// Creates a new instance.
+    public init(volume: Float = SoundTransform.defaultVolume, pan: Float = SoundTransform.defaultPan) {
+        self.volume = volume
+        self.pan = pan
+    }
+
     func apply(_ playerNode: AVAudioPlayerNode?) {
         playerNode?.volume = volume
         playerNode?.pan = pan

Sources/RTMP/RTMPStream.swift

@@ -685,6 +685,12 @@ public actor RTMPStream {
 
 extension RTMPStream: HKStream {
     // MARK: HKStream
+    public var soundTransform: SoundTransform? {
+        get async {
+            await player.soundTransfrom
+        }
+    }
+
     public var audioSettings: AudioCodecSettings {
         ingestor.audioSettings
     }
@@ -701,6 +707,10 @@ extension RTMPStream: HKStream {
         ingestor.videoSettings = videoSettings
     }
 
+    public func setSoundTransform(_ soundTransform: SoundTransform) async {
+        await player.setSoundTransform(soundTransform)
+    }
+
     public func append(_ sampleBuffer: CMSampleBuffer) {
         switch sampleBuffer.formatDescription?.mediaType {
         case .video: