Invoke delegate the stream(_ stream: NetStream, didOutput video: CMSa…

Examples/iOS/PlaybackViewController.swift

@@ -16,6 +16,7 @@ final class PlaybackViewController: UIViewController {
     override func viewDidLoad() {
         super.viewDidLoad()
         rtmpStream = RTMPStream(connection: rtmpConnection)
+        rtmpStream.delegate = self
     }
 
     override func viewWillAppear(_ animated: Bool) {
@@ -119,3 +120,31 @@ extension PlaybackViewController: AVPictureInPictureSampleBufferPlaybackDelegate
         completionHandler()
     }
 }
+
+extension PlaybackViewController: NetStreamDelegate {
+    // MARK: NetStreamDelegate
+    func stream(_ stream: NetStream, didOutput audio: AVAudioBuffer, presentationTimeStamp: CMTime) {
+    }
+
+    func stream(_ stream: NetStream, didOutput video: CMSampleBuffer) {
+    }
+
+    func stream(_ stream: NetStream, sessionWasInterrupted session: AVCaptureSession, reason: AVCaptureSession.InterruptionReason) {
+    }
+
+    func stream(_ stream: NetStream, sessionInterruptionEnded session: AVCaptureSession, reason: AVCaptureSession.InterruptionReason) {
+    }
+
+    func stream(_ stream: NetStream, videoCodecErrorOccurred error: VideoCodec.Error) {
+    }
+
+    func stream(_ stream: NetStream, audioCodecErrorOccurred error: HaishinKit.AudioCodec.Error) {
+    }
+
+    func streamWillDropFrame(_ stream: NetStream) -> Bool {
+        return false
+    }
+
+    func streamDidOpen(_ stream: NetStream) {
+    }
+}

Sources/Media/IOMixer.swift

@@ -287,6 +287,7 @@ extension IOMixer: IOUnitDecoding {
 extension IOMixer: MediaLinkDelegate {
     // MARK: MediaLinkDelegate
     func mediaLink(_ mediaLink: MediaLink, dequeue sampleBuffer: CMSampleBuffer) {
+        delegate?.mixer(self, didOutput: sampleBuffer)
         drawable?.enqueue(sampleBuffer)
     }