草庐IT

android - 改造JavaRx2线程中断

我正在创建如下嵌套请求(省略了一些错误处理):returnSingle.create((SingleOnSubscribe)emitter->getPages().subscribe(pages->getPageData(emitter,pages),emitter::onError)).compose(applySchedulers());//...privatevoidgetPageData(SingleEmitteremitter,Listpages){service.getPage(pages.get(0).id).subscribe(emitter::onSuccess,e-