ThePain/Swiftgram
1
0
Fork 0
mirror of https://github.com/Swiftgram/Telegram-iOS.git synced 2025-10-09 03:20:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

Log async missuse

Browse Source
This commit is contained in:
Kylmakalle 2025-02-04 22:04:57 +02:00
parent 174568088a
commit 1d80ad6a6b
1 changed files with 22 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
Swiftgram/SGSwiftSignalKit/Sources/SGSwiftSignalKit.swift
View File

@ -39,12 +39,21 @@ public struct SignalError<E>: Error {
// Extension for Signals with Error types
extension Signal {
@available(iOS 13.0, *)
public func awaitable() async throws -> T {
public func awaitable(file: String = #file, line: Int = #line) async throws -> T {
return try await withCheckedThrowingContinuation { continuation in
var disposable: Disposable?
let hasResumed = Atomic<Bool>(value: false)
disposable = self.start(
next: { value in
continuation.resume(returning: value)
if !hasResumed.with({ $0 }) {
let _ = hasResumed.swap(true)
continuation.resume(returning: value)
} else {
#if DEBUG
// Consider using awaitableStream() or |> take(1)
assertionFailure("awaitable Signal emitted more than one value. \(file):\(line)")
#endif
}
disposable?.dispose()
},
error: { error in
@ -66,12 +75,21 @@ extension Signal {
// Extension for Signals with NoError
extension Signal where E == NoError {
@available(iOS 13.0, *)
public func awaitable() async -> T {
public func awaitable(file: String = #file, line: Int = #line) async -> T {
return await withCheckedContinuation { continuation in
var disposable: Disposable?
let hasResumed = Atomic<Bool>(value: false)
disposable = self.start(
next: { value in
continuation.resume(returning: value)
if !hasResumed.with({ $0 }) {
let _ = hasResumed.swap(true)
continuation.resume(returning: value)
} else {
#if DEBUG
// Consider using awaitableStream() or |> take(1)
assertionFailure("awaitable Signal emitted more than one value. \(file):\(line)")
#endif
}
disposable?.dispose()
},
error: { _ in