我正在使用AWS Amplify库https://github.com/aws-amplify/amplify-swift与Cognito服务进行通信.大多数函数都使用新的异步/等待方法进行了重写.
请看以下方法:
func fetchAuthSession() async throws -> AuthSession {
return try await Amplify.Auth.fetchAuthSession()
}
如何使用RxSWIFT包装等待调用以返回Observable<AuthSession>？
使用Observable.create创建Observable.
用Task { ... }来执行async项工作.
在Observable.create中使用Task { ... }来执行Observable中的async工作.
像这样的事情应该会奏效:
let authSessionObservable: Observable<AuthSession> = Observable.create { observer in
let task = Task {
do {
let session = try await Amplify.Auth.fetchAuthSession()
observer.on(.next(session))
observer.on(.completed)
} catch {
observer.on(.error(error))
}
}
return Disposables.create {
task.cancel()
}
}