Служба отдыха с Java, наблюдаемая из службы Executer

Question

У меня есть веб-сервис для отдыха, который возвращает DeferredResults. Я реализовал JavaRx Observable из службы executer, которая возвращает Future. Я хотел, чтобы этот веб-сервис не блокировался, но, похоже, он блокирует операцию.

Считаете ли вы способ, которым я пользовался службой экстерьера, здоров?

DeferredResult result = new DeferredResult(); 
    Observable<ResultEntity> observable = Observable 
        .from(executerService.submit(callable)); 
      observable.subscribe(new Subscriber<ResultEntity>() { 
       @Override 
       public void onCompleted() { 

       } 

       @Override 
       public void onError(Throwable throwable) { 
        result.setErrorResult(throwable.getMessage()); 
       } 

       @Override 
       public void onNext(ResultEntity r) { 
        result.setResult(t); 

       } 

      }); 

Answer 1

Observable.from(Future) блокирует операцию, как указано в документации. Вместо этого вы должны использовать Observable.from(Future,Scheduler).

Answer 2

Если у вас есть Callable, вы можете использовать fromCallable:

Observable.fromCallable(callable) 
.subscribeOn(Schedulers.from(executorService)) 
.subscribe(...)