PoseProvider

public protocol PoseProvider: Sendable {
    func poses() -> AsyncStream<Pose>
}

Qualquer coisa que produza poses. Cada chamada a poses() começa um fluxo novo. Quando o consumidor para de iterar (sai do laço ou cancela sua tarefa), o fluxo termina e o provider libera o que estava usando.

VisionPoseProvider

Módulo KinesiaMotionVision, só iOS. Veja o guia.

init(camera: Camera = .front, minimumConfidence: Float = 0.3)

Membro
captureSession: AVCaptureSession	Para um AVCaptureVideoPreviewLayer.
camera: Camera	.front ou .back.
minimumConfidence: Float	Pontos com menos confiança são descartados.
static isAuthorized: Bool	Se já há permissão de câmera.
static requestAccess() async -> Bool	Pede a permissão.

VideoPoseProvider

Módulo KinesiaMotionVision, iOS e macOS. Desde a 0.2.0. Veja Testes e gravações.

init(url: URL,
     mirrored: Bool = false,
     minimumConfidence: Float = 0.3,
     maximumFrameRate: Double = 30,
     realTime: Bool = false)

Membro
url: URL	O vídeo (.mov, .mp4). Processado no dispositivo.
mirrored: Bool	true quando o vídeo parece um espelho; os lados passam a ser os do paciente.
minimumConfidence: Float	Pontos com menos confiança são descartados.
maximumFrameRate: Double	Pula quadros mais próximos que 1 / maximumFrameRate.
realTime: Bool	Espera entre quadros como no vídeo.
readAll() async throws -> [Pose]	Todas as poses de uma vez. Lança ReadError se não conseguir ler o arquivo.

RecordedPoseProvider

Módulo KinesiaMotion. Veja Testes e gravações.

init(_ recording: [Pose], realTime: Bool = false)

Escrever o seu

Por exemplo, para poses vindas de outro detector:

struct MyDetectorProvider: PoseProvider {
    let detector: MyDetector

    func poses() -> AsyncStream<Pose> {
        AsyncStream(bufferingPolicy: .bufferingNewest(1)) { continuation in
            let token = detector.onFrame { result in
                continuation.yield(Pose(
                    points: result.pointsInPixels,      // y para baixo
                    timestamp: result.time,
                    imageSize: result.imageSize,
                    confidence: result.confidence
                ))
            }
            continuation.onTermination = { _ in detector.stop(token) }
        }
    }
}

Respeite o contrato de Pose: pixels com y para baixo, lados anatômicos e só pontos confiáveis. .bufferingNewest(1) evita acumular quadros velhos se o consumidor estiver lento.