Как реализовать уведомления об обертке свойств в рамках в разных контекстах в Swift? ⇐ IOS

[Anonymous]

Я пытаюсь создать обертку свойства, которая может управлять общим состоянием в любом контексте, который может быть уведомлен, если изменения произойдут откуда -то еще. Тем не менее, я не могу найти способ создать шаблон наблюдателя, который могут использовать обертки свойств. фон. Уведомление предпочтительно будет вызвано синхронно, если запустить из одного и того же потока или актера или иным образом асинхронно. Мне не нужно беспокоиться о условиях гонки из уведомления, потому что государство должно достичь согласованности событий.// A single source of truth storage container.
final class MemoryShared: Sendable {
let state = Mutex(0)

func withLock(_ action: (inout Value) -> Void) {
state.withLock(action)
notifyObservers()
}

func get() -> Value
func notifyObservers()
func addObserver()
}

// Some shared state used across the app
static let globalCount = MemoryShared(0)

// A property wrapper to access the shared state and receive changes
@propertyWrapper
struct SharedState {
public var wrappedValue: T {
get { state.get() }
nonmutating set { // Can't set directly }
}

var publisher: Publisher {}

init(state: MemoryShared) {
// ...
}
}

// I'd like to use it in multiple places:

@Observable
class MyObservable {
@SharedState(globalCount)
var count: Int
}

actor MyBackgroundActor {
@SharedState(globalCount)
var count: Int
}

@MainActor
struct MyView: View {
@SharedState(globalCount)
var count: Int
}
< /code>
Что я попробовал < /h3>
Все примеры ниже используют обертку свойства в классе @mainactor. Однако такая же проблема происходит независимо от того, в каком контексте я использую обертку в: обратный вызов уведомления никогда не вызывается в контексте, с которой была создана обертка свойства.final class MemoryShared: Sendable {
// Stores the callback for later.
public func subscribe(callback: @escaping @isolated(any) (Value) -> Void) -> Subscription
}

@propertyWrapper
struct SharedState {
init(state: MemoryShared) {
MainActor.assertIsolated() // Works!
state.subscribe {
MainActor.assertIsolated() // Fails
self.publisher.send()
}
}
}
< /code>
Я попытался захватить изоляцию в задаче с Asyncstream. Это на самом деле компилируется без проблем с отправляемыми, но все еще терпит неудачу: < /p>
@propertyWrapper
struct SharedState {
init(isolation: isolated (any Actor)? = #isolation, state: MemoryShared) {
let (taskStream, continuation) = AsyncStream.makeStream()
// The shared state sends new values to the continuation.
subscription = state.subscribe(continuation: continuation)

MainActor.assertIsolated() // Works!

let task = Task {
_ = isolation
for await value in taskStream {
_ = isolation
MainActor.assertIsolated() // Fails
}
}
}
}
< /code>
Я попытался использовать несколько предметов и издателей: < /p>
final class MemoryShared: Sendable {
let subject: PassthroughSubject // ...
var publisher: Publisher {} // ...
}

@propertyWrapper
final class SharedState {
var localSubject: Subject

init(state: MemoryShared) {
MainActor.assertIsolated() // Works!
handle = localSubject.sink {
MainActor.assertIsolated() // Fails
}

stateHandle = state.publisher.subscribe(localSubject)
}
}
< /code>
Я также попробовал: < /p>

• Использование NotificationCenter < /li>
  Сделать обертку свойства < /li>
  Использование nskeyvalueobserving < /li>
  Использование класса коробки, которая находится в рамках завершения. @_inheritActorContext.

Все это не работает, потому что событие никогда не вызывается из потока, в которой находится обертка свойства.>

Подробнее здесь: https://stackoverflow.com/questions/794 ... ferent-con