我试图使用项目反应堆的Mono.fromCallable(Callable)执行异步操作,我注意到,在我的测试用例中,它似乎在调用线程上运行。默认情况下,Mono.fromCallable(Callable)是否在某个地方使用调用线程?我从中看到,我应该做如下事情: return /* make a remote synchronous
我似乎无法接受Observable.fromCallable()调用的语法,如下所示。我正在使用我在fromCallable()方法的示例中看到的确切语法,尽管使用的是Java示例,而不是Groovy,因为我似乎找不到任何Groovy示例。这是我的密码:{
// Emit an observable that waits for the call in the closure passed to fromCallable我之所以使用fromCallable(),是因为我读到