class MaybeInteractor implements Interactor<DisposableMaybeObserver, P> {

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

  public  MaybeInteractor(ThreadExecutor threadExecutor, PostExecutionThread postExecutionThread);

}