ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-12-24 07:05:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix request stream channels

Browse Source
This commit is contained in:
Ali
2022-02-27 02:47:25 +04:00
parent 217fb6c899
commit 39ebfb356e
3 changed files with 25 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
submodules/TelegramVoip/Sources/GroupCallContext.swift
View File

@@ -55,7 +55,28 @@ private final class NetworkBroadcastPartSource: BroadcastPartSource {
func requestTime(completion: @escaping (Int64) -> Void) -> Disposable {
if self.isExternalStream {
return self.engine.calls.requestStreamState(callId: self.callId, accessHash: self.accessHash).start(next: { result in
let dataSource: Signal<AudioBroadcastDataSource?, NoError>
if let dataSourceValue = self.dataSource {
dataSource = .single(dataSourceValue)
} else {
dataSource = self.engine.calls.getAudioBroadcastDataSource(callId: self.callId, accessHash: self.accessHash)
}
let engine = self.engine
let callId = self.callId
let accessHash = self.accessHash
return (dataSource
|> deliverOn(self.queue)
|> mapToSignal { [weak self] dataSource -> Signal<EngineCallStreamState?, NoError> in
if let dataSource = dataSource {
self?.dataSource = dataSource
return engine.calls.requestStreamState(dataSource: dataSource, callId: callId, accessHash: accessHash)
} else {
return .single(nil)
}
}
|> deliverOn(self.queue)).start(next: { result in
if let channel = result?.channels.first {
completion(channel.latestTimestamp)
} else {