package/ios/CameraView.swift

@@ -62,8 +62,6 @@ public final class CameraView: UIView, CameraSessionDelegate {
   @objc var onStarted: RCTDirectEventBlock?
   @objc var onStopped: RCTDirectEventBlock?
   @objc var onViewReady: RCTDirectEventBlock?
-  @objc var onInitReady: RCTDirectEventBlock?
-  @objc var onVideoChunkReady: RCTDirectEventBlock?
   @objc var onCodeScanned: RCTDirectEventBlock?
   // zoom
   @objc var enableZoomGesture = false {
@@ -338,26 +336,6 @@ public final class CameraView: UIView, CameraSessionDelegate {
     #endif
   }
 
-  func onVideoChunkReady(chunk: ChunkedRecorder.Chunk) {
-    ReactLogger.log(level: .info, message: "Chunk ready: \(chunk)")
-    
-    guard let onVideoChunkReady, let onInitReady else {
-      return
-    }
-    
-    switch chunk.type {
-    case .initialization:
-      onInitReady([
-        "filepath": chunk.url.path,
-      ])
-    case .data(index: let index):
-      onVideoChunkReady([
-        "filepath": chunk.url.path,
-        "index": index,
-      ])
-    }
-  }
-
   func onCodeScanned(codes: [CameraSession.Code], scannerFrame: CameraSession.CodeScannerFrame) {
     guard let onCodeScanned = onCodeScanned else {
       return

package/ios/CameraViewManager.m

@@ -55,8 +55,6 @@ RCT_EXPORT_VIEW_PROPERTY(onInitialized, RCTDirectEventBlock);
 RCT_EXPORT_VIEW_PROPERTY(onStarted, RCTDirectEventBlock);
 RCT_EXPORT_VIEW_PROPERTY(onStopped, RCTDirectEventBlock);
 RCT_EXPORT_VIEW_PROPERTY(onViewReady, RCTDirectEventBlock);
-RCT_EXPORT_VIEW_PROPERTY(onInitReady, RCTDirectEventBlock);
-RCT_EXPORT_VIEW_PROPERTY(onVideoChunkReady, RCTDirectEventBlock);
 // Code Scanner
 RCT_EXPORT_VIEW_PROPERTY(codeScannerOptions, NSDictionary);
 RCT_EXPORT_VIEW_PROPERTY(onCodeScanned, RCTDirectEventBlock);

package/ios/Core/CameraSession+Video.swift

@@ -34,14 +34,6 @@ extension CameraSession {
 
       let enableAudio = self.configuration?.audio != .disabled
 
-      // Callback for when new chunks are ready
-      let onChunkReady: (ChunkedRecorder.Chunk) -> Void = { chunk in
-        guard let delegate = self.delegate else {
-          return
-        }
-        delegate.onVideoChunkReady(chunk: chunk)
-      }
-
       // Callback for when the recording ends
       let onFinish = { (recordingSession: RecordingSession, status: AVAssetWriter.Status, error: Error?) in
         defer {
@@ -97,7 +89,6 @@ extension CameraSession {
         // Create RecordingSession for the temp file
         let recordingSession = try RecordingSession(url: tempURL,
                                                     fileType: options.fileType,
-                                                    onChunkReady: onChunkReady,
                                                     completion: onFinish)
 
         // Init Audio + Activate Audio Session (optional)

package/ios/Core/CameraSessionDelegate.swift

@@ -33,10 +33,6 @@ protocol CameraSessionDelegate: AnyObject {
    Called for every frame (if video or frameProcessor is enabled)
    */
   func onFrame(sampleBuffer: CMSampleBuffer)
-  /**
-   Called whenever a new video chunk is available
-   */
-  func onVideoChunkReady(chunk: ChunkedRecorder.Chunk)
   /**
    Called whenever a QR/Barcode has been scanned. Only if the CodeScanner Output is enabled
    */

package/ios/Core/ChunkedRecorder.swift

@@ -12,24 +12,14 @@ import AVFoundation
 
 class ChunkedRecorder: NSObject {
   
-  enum ChunkType {
-    case initialization
-    case data(index: UInt64)
-  }
-
-  struct Chunk {
-    let url: URL
-    let type: ChunkType
-  }
-  
   let outputURL: URL
-  let onChunkReady: ((Chunk) -> Void)
   
-  private var index: UInt64 = 0
+  private var initSegment: Data?
+  private var index: Int = 0
   
-  init(url: URL, onChunkReady: @escaping ((Chunk) -> Void)) throws {
+  init(url: URL) throws {
     outputURL = url
-    self.onChunkReady = onChunkReady
+    
     guard FileManager.default.fileExists(atPath: outputURL.path) else {
       throw CameraError.unknown(message: "output directory does not exist at: \(outputURL.path)", cause: nil)
     }
@@ -55,31 +45,26 @@ extension ChunkedRecorder: AVAssetWriterDelegate {
   }
   
   private func saveInitSegment(_ data: Data) {     
-    let url = outputURL.appendingPathComponent("init.mp4")
-    save(data: data, url: url)
-    onChunkReady(url: url, type: .initialization)
+    initSegment = data
   }
   
   private func saveSegment(_ data: Data) {
-    defer {
+    guard let initSegment else {
+      print("missing init segment")
+      return
+    }
+    
+    let file = String(format: "%06d.mp4", index)
     index += 1
-    }
-    let name = String(format: "%06d.mp4", index)
-    let url = outputURL.appendingPathComponent(name)
-    save(data: data, url: url)
-    onChunkReady(url: url, type: .data(index: index))
-  }
+    let url = outputURL.appendingPathComponent(file)
     
-  private func save(data: Data, url: URL) {
     do {
-      try data.write(to: url)
+      let outputData = initSegment + data
+      try outputData.write(to: url)
+      print("writing", data.count, "to", url)
     } catch {
-      ReactLogger.log(level: .error, message: "Unable to write \(url): \(error.localizedDescription)")
+      print("Error--->", error)
     }
   }
   
-  private func onChunkReady(url: URL, type: ChunkType) {
-    onChunkReady(Chunk(url: url, type: type))
-  }
-  
 }

package/ios/Core/RecordingSession.swift

@@ -74,12 +74,11 @@ class RecordingSession {
 
   init(url: URL,
        fileType: AVFileType,
-       onChunkReady: @escaping ((ChunkedRecorder.Chunk) -> Void),
        completion: @escaping (RecordingSession, AVAssetWriter.Status, Error?) -> Void) throws {
     completionHandler = completion
 
     do {
-      recorder = try ChunkedRecorder(url: url.deletingLastPathComponent(), onChunkReady: onChunkReady)
+      recorder = try ChunkedRecorder(url: url.deletingLastPathComponent())
       assetWriter = AVAssetWriter(contentType: UTType(fileType.rawValue)!)
       assetWriter.shouldOptimizeForNetworkUse = false
       assetWriter.outputFileTypeProfile = .mpeg4AppleHLS