Выставьте @publised var из протокола актера в Swift 6 ⇐ IOS

[Anonymous]

Я хочу прослушать изменения (например, логического) значения в одном из моих актеров.protocol MyServiceProtocol: Actor {
var myValuePublisher: Published.Publisher { get }
}

actor MyService: MyServiceProtocol {
@Published private(set) var myValue = false
var myValuePublisher: Published.Publisher { $myValue }

// ... (modifies myValue)

}

Поскольку мы не можем разоблачить значение @publised в протоколе, я использовал версию издателя выше.@MainActor
final class MyViewModel {
private let myService: MyServiceProtocol = MyService()

func testMyService() {
// Accessing myValuePublisher as an async stream
Task {
for await newValue in await myService.myValuePublisher.values {
print("New value :", newValue)
}
}

// OR

// Accessing myValuePublisher with Combine
let cancellable = await myService.myValuePublisher.sink { value in
print("New value :", newValue)
}
}
}
< /code>
Но я получаю эту ошибку компиляции для использования Async Stream: < /p>
Non-sendable type 'Published.Publisher' of property 'myValuePublisher' cannot exit actor-isolated context

и этот для подхода Combine :
Actor-isolated property 'myValuePublisher' can not be referenced from the main actor

Поскольку Publisher не отправляется, он не работает со Swift 6. Итак, как я могу опубликовать это значение? Является ли асинкенция < /code> единственный способ сейчас с Swift 6 или я что -то упускаю? : По -видимому, я не должен выставлять издателя, так как он не готов к Swift 6 (и, вероятно, никогда не будет, как предполагает @sweeper)
Итак, вот моя попытка с асинхринсом :
protocol MyServiceProtocol: Actor {
var myValue: Bool { get }
func myValueStream() -> AsyncStream
}

actor MyService: MyServiceProtocol {
private(set) var myValue = false
private var myValueContinuation: AsyncStream.Continuation?

deinit {
myValueContinuation?.finish() // Not sure if needed
}

private func modifyValue() {
myValue = true
myValueContinuation?.yield(true)
}

public func myValueStream() -> AsyncStream {
AsyncStream { continuation in
myValueContinuation = continuation
continuation.yield(myValue)
}
}
}

@MainActor
final class MyViewModel {
private let myService: MyServiceProtocol = MyService()

func testMyService() {
Task {
for await newValue in await myService.myValueStream() {
print("New value: ", newValue)
}
}
}
}



Подробнее здесь: https://stackoverflow.com/questions/796 ... in-swift-6