class CompletableInteractor implements Interactor<DisposableCompletableObserver, P> {

  @Override
  public void execute(DisposableCompletableObserver observer, P params) {
    DisposableCompletableObserver disposableObserver = buildReactiveStream(params)
        .subscribeOn(Schedulers.from(threadExecutor))
        .observeOn(postExecutionThread.getScheduler())
        .subscribeWith(observer);
    disposables.add(disposableObserver);
  }

  public  CompletableInteractor(ThreadExecutor threadExecutor,
      PostExecutionThread postExecutionThread);

}