我有打网络电话的功能。可以同时多次调用它,并且每个调用同时运行。
getDataTask() // it is subscribed on the background thread and observed on the main thread
.subscribe(
{ result -> onResult(result) },
{ onError() }
)
.addToDisposables()
我可以毫无问题地检索数据。onResult函数将ViewModel中的MutableLiveData字段更新为
private v
我想同时给两个不同的服务打网络电话。最后,我将2个Response对象压缩到一个流中。我正在使用一个Callable,但我不确定我是否用正确的方式来做这件事。似乎我仍然会被第一次get()调用Future所阻塞,对吗?谁能告诉我我是不是在正确的轨道上?到目前为止,这就是我所拥有的:
// submit the 2 calls to the thread pool
ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
Future<
当我试图按我的观点打一个网络电话时,我遇到了一个错误。这是一个有问题的错误:
Invalid conversion from throwing function of type '@Sendable () async throws -> ()' to non-throwing function type '@Sendable () async -> Void'
我试图让我的代码返回一个Result数组到我的视图中,以显示在屏幕上。我怎样才能消除这个错误?任何帮助都将不胜感激。
我的视图代码:
struct MoviesScrollView: View