java - 如何等待flowable onComplete？

Question

在 RxJava2 中，这是我的代码:

public void myMethod() {
Flowable.create(e->{
  // do sth.
}, BackpressureStrategy.BUFFER)
.subscribeOn(Schedulers.computation())
.observeOn(Schedulers.io())
.subscribe(new Subscriber<ContentsWithChannelVO>() {
  @Override
  public void onSubscribe(Subscription subscription) { // do sth. }

  @Override
  public void onNext(ContentsWithChannelVO contentAndChannel) { // do sth. }

  @Override
  public void onError(Throwable throwable) { // do sth. }

  @Override
  public void onComplete() { // do sth. }
});
doSomething();
}

这是一个同步问题。

我想知道如何让我的方法等待 flowable onComplete，也就是说doSomething()将在 flowable 之后调用已完成。

我已经搜索过了，但没有帮助。

Answer 1

您可以使用concat运算符，但您需要将方法包装在另一个可观察对象中。

Concat waits to subscribe to each additional Observable that you pass to it until the previous Observable completes.