RTCAudioTrackSink ラッパーを MediaStream に追加する

CHANGES.md

@@ -18,6 +18,11 @@
   - @t-miya
 - [ADD] MediaChannel に libwebrtc の統計情報を取得する `getStats` メソッドを追加する
   - @t-miya
+- [ADD] MediaStream に RTCAudioTrackSink を RTCAudioTrack と関連付ける / 関連付けを解除するためのメソッドを追加する
+  - 追加したメソッド
+    - `addAudioTrackSink(_ sink: RTCAudioTrackSink)`
+    - `removeAudioTrackSink(_ sink: RTCAudioTrackSink)`
+  - @zztkm
 
 ### misc
 

Sora/MediaStream.swift

@@ -63,6 +63,16 @@ public protocol MediaStream: AnyObject {
   /// このプロパティはロールがサブスクライバーの場合のみ有効です。
   var remoteAudioVolume: Double? { get set }
 
+  // MARK: 音声データ取得
+
+  /// RTCAudioTrackSink を RTCAudioTrack に関連付けます。
+  /// 追加済みのシンクを再度追加した場合は何もしません。
+  func addAudioTrackSink(_ sink: RTCAudioTrackSink)
+
+  /// RTCAudioTrackSink の関連付けを解除します。
+  /// 未追加の RTCAudioTrackSink を指定した場合は何もしません。
+  func removeAudioTrackSink(_ sink: RTCAudioTrackSink)
+
   // MARK: 映像フレームの送信
 
   /// 映像フィルター
@@ -210,6 +220,16 @@ class BasicMediaStream: MediaStream {
     }
   }
 
+  func addAudioTrackSink(_ sink: RTCAudioTrackSink) {
+    Logger.debug(type: .mediaStream, message: "add audio track sink \(sink)")
+    nativeAudioTrack?.add(sink)
+  }
+
+  func removeAudioTrackSink(_ sink: RTCAudioTrackSink) {
+    Logger.debug(type: .mediaStream, message: "remove audio track sink \(sink)")
+    nativeAudioTrack?.remove(sink)
+  }
+
   init(peerChannel: PeerChannel, nativeStream: RTCMediaStream) {
     self.peerChannel = peerChannel
     self.nativeStream = nativeStream

Sora/Sora.swift

@@ -124,10 +124,11 @@ public final class Sora {
   public func connect(
     configuration: Configuration,
     webRTCConfiguration: WebRTCConfiguration = WebRTCConfiguration(),
-    handler: @escaping (
-      _ mediaChannel: MediaChannel?,
-      _ error: Error?
-    ) -> Void
+    handler:
+      @escaping (
+        _ mediaChannel: MediaChannel?,
+        _ error: Error?
+      ) -> Void
   ) -> ConnectionTask {
     let mediaChan = MediaChannel(manager: self, configuration: configuration)
     mediaChan.internalHandlers.onDisconnectLegacy = { [weak self, weak mediaChan] error in