Início / coding / Perguntas / 79335713
Accepted
Deepak Sharma
Asked: 2025-01-07 18:49:33 +0800 CST

Erros de compilação do Swift 6 ao monitorar valores publicados de um ator em uma tarefa

  • 772

O código a seguir dá erro ao compilar na versão de linguagem Swift 6 no Xcode. Isso é um problema de arquitetura ou tem uma solução fácil? O tipo Boolé Sendable, mas seu publicador não é.

Non-sendable type 'Published<Bool>.Publisher' in implicitly asynchronous access to actor-isolated property '$isRecording' cannot cross actor boundary

import Foundation

final class Recorder {
    
    var writer = Writer()
    var isRecording = false
    
    func startRecording() {
        Task { [writer] in
            await writer.startRecording()
            print("started recording")
        }
    }
    
    func stopRecording() {
        Task { [writer] in
            await writer.stopRecording()
            print("stopped recording")
        }
    }
    
    func observeValues() {
        
        Task {
            for await value in await writer.$isRecording.values {
                isRecording = value
            }
        }
    }
}

actor Writer {
    @Published private(set) public var isRecording = false
    
    func startRecording() {
        isRecording = true
    }
    
    func stopRecording() {
        isRecording = false
    }
}

Consulte esta captura de tela para ver os erros reais que vejo no código de exemplo do AVCam (com a única modificação de colocar @preconcurrency) import AVFoundation.

Consulte esta captura de tela para ver os erros reais no código de exemplo do AVCam que vejo (sem modificações)

1 respostas

  1. Best Answer

    Em vez de @Publishede então obter o values, eu usaria diretamente um AsyncStreampara entregar os valores. AsyncStreamé enviável se os elementos do fluxo forem enviáveis.

    @propertyWrapper
struct Streamed<T: Sendable> {
    private var continuation: AsyncStream<T>.Continuation
    
    var projectedValue: AsyncStream<T>
    
    var wrappedValue: T {
        didSet {
            continuation.yield(wrappedValue)
        }
    }
    
    init(wrappedValue: T) {
        self.wrappedValue = wrappedValue
        (projectedValue, continuation) = AsyncStream.makeStream()
        continuation.yield(wrappedValue)
    }
}

actor Writer {
    @Streamed private(set) public var isRecording = false
    
    func startRecording() {
        isRecording = true
    }
    
    func stopRecording() {
        isRecording = false
    }
}

    Então em observedValues,

    @MainActor
func observeValues() {
    Task {
        for await value in await writer.$isRecording {
            isRecording = value
        }
    }
}

    Observe que, para isRecording = valueestar seguro, um observeValuesou o todo Recorderprecisa ser isolado para um ator global.

    • 1

relate perguntas