RxAVFoundation

RxAVFoundation (based on RxSwift)

Basic usage.

var session = AVCaptureSession()

session
    .rx
    .configure(captureDevice: captureDevice) // define 'captureDevice' first
    
session
    .rx
    .videoCaptureOutput()
    .observeOn(MainScheduler.instance)
    .subscribe { [unowned self] (event) in
        switch event {
            case .next(let captureOutput):
                self.processVideo(sampleBuffer: captureOutput.sampleBuffer) // define the method first
            case .error(let error):
                os_log("error: %@", "\(error)")
            case .completed:                
                break // never happens
        }
    }
    .disposed(by: disposeBag)
    
session
    .rx
    .depthCaptureOutput()
    .observeOn(MainScheduler.instance)
    .subscribe { [unowned self] (event) in
        switch event {
            case .next(let captureOutput):
                self.processDepth(depthData: captureOutput.depthData) // define the method first
            case .error(let error):
                os_log("error: %@", "\(error)")
            case .completed:                
                break // never happens
            }
    }
    .disposed(by: disposeBag)
    
session
    .rx
    .outputs
    .asObservable()
    .flatMap { [unowned self] outputs in
        self.session.rx.synchronizerOutput(dataOutputs: outputs)
    }
    .observeOn(MainScheduler.instance)
    .subscribe { [unowned self] (event) in
        switch event {
        case .next(let synchronizerOutput):
            let videoDataOutput = self.session.outputs.filter { $0 is AVCaptureVideoDataOutput }.first!
            let depthDataOutput = self.session.outputs.filter { $0 is AVCaptureDepthDataOutput }.first!
            // ...
        case .error(let error):
            os_log("error: %@", "\(error)")
        case .completed:                
            break // never happens
        }
    }
    .disposed(by: disposeBag)
    
session
    .rx
    .startRunning()

Carthage setup.

github "RxSwiftCommunity/RxAVFoundation" ~> 0.1.0

Copyright (c) RxSwiftCommunity