Desolate
Prototype actor and async/await toolkit for Swift 5.5+
\"\(item)\"" case .store(item: let item, ref: _): return "POST: \"\(item)\"" case .add(item: let item): return "POST: \"\(item)\"" case .get(key: let key, ref: _): return "GET: \(key)" case .getAll(ref: _): return "GET: *" case .delete(key: let key): return "DELETE: \(key)" } } } actor Store: AbstractDesolate { public var status: Signal = .running private var storage: [String: (String, Date)] = [:] public func onMessage(msg: StoreEvent) async -> Signal { print("Received: \(msg)") switch msg { case .update(let key, let item): storage[key] = (item, Date()) case .store(let item, let ref): let key = UUID().uuidString storage[key] = (item, Date()) ref.tell(with: key) case .get(let key, let ref): ref.tell(with: storage[key]?.0) case .getAll(let ref): ref.tell(with: storage.values.sorted { $0.1 <= $1.1 } .map{ $0.0 }) case .delete(let key): storage.removeValue(forKey: key) } return .running } } let desolate = Desolate(of: Store()) desolate.tell(with: .add(item: "Hello")) // Passing message to Actor while maintaining actor-isolation ">
import Desolate enum StoreEvent: CustomStringConvertible { case update(key: String, item: String) case store(item: String, ref: RecipientRef<String>) case add(item: String) case get(key: String, ref: RecipientRef<String?>) case getAll(ref: RecipientRef<[String]>) case delete(key: String) var description: String { switch self { case .update(key: let key, item: let item): return "PUT/PATCH: \(key) -> \"\(item)\"" case .store(item: let item, ref: _): return "POST: \"\(item)\"" case .add(item: let item): return "POST: \"\(item)\"" case .get(key: let key, ref: _): return "GET: \(key)" case .getAll(ref: _): return "GET: *" case .delete(key: let key): return "DELETE: \(key)" } } } actor Store: AbstractDesolate { public var status: Signal = .running private var storage: [String: (String, Date)] = [:] public func onMessage(msg: StoreEvent) async -> Signal { print("Received: \(msg)") switch msg { case .update(let key, let item): storage[key] = (item, Date()) case .store(let item, let ref): let key = UUID().uuidString storage[key] = (item, Date()) ref.tell(with: key) case .get(let key, let ref): ref.tell(with: storage[key]?.0) case .getAll(let ref): ref.tell(with: storage.values.sorted { $0.1 <= $1.1 } .map{ $0.0 }) case .delete(let key): storage.removeValue(forKey: key) } return .running } } let desolate = Desolate(of: Store()) desolate.tell(with: .add(item: "Hello")) // Passing message to Actor while maintaining actor-isolation
Feedback
If you have any feedback, feel free to reach out through the issues tab or through my Twitter @d_exclaimation.
39 Sep 21, 2022
132 Jan 6, 2023
2 Jun 29, 2022
89 Dec 30, 2022
136 Dec 25, 2022
833 Jan 3, 2023
4 Oct 6, 2022
2.3k Jan 3, 2023
19 May 12, 2022
4 Dec 29, 2022
31 Dec 14, 2022
2 Nov 25, 2022
972 Dec 17, 2022
73 Dec 13, 2022
67 Dec 31, 2022
7 Dec 19, 2022
0 Dec 7, 2021
23 Nov 8, 2022