[WIP] Stories

This commit is contained in:
Ali
2023-06-09 16:04:42 +04:00
parent 9b7e421107
commit 7015298cd5
3 changed files with 26 additions and 5 deletions

View File

@@ -839,6 +839,9 @@ public final class PeerExpiringStoryListContext {
private var pollDisposable: Disposable?
private let statePromise = Promise<State>()
var state: Signal<State, NoError> {
return self.statePromise.get()
}
init(queue: Queue, account: Account, peerId: EnginePeer.Id) {
self.queue = queue
@@ -1034,6 +1037,12 @@ public final class PeerExpiringStoryListContext {
private let queue: Queue
private let impl: QueueLocalObject<Impl>
public var state: Signal<State, NoError> {
return impl.signalWith { impl, subscriber in
return impl.state.start(next: subscriber.putNext)
}
}
public init(account: Account, peerId: EnginePeer.Id) {
let queue = Queue.mainQueue()
self.queue = queue