有一个Flowable没有包装器的创建：
Flowable flowable = Flowable.create(..., BUFFER).subscribeOn(newThread());
它正在被订阅（异步）：
flowable.subscribe(...);
一段时间后
Thread.sleep(...);
它正在被订阅（同步）：
flowable.blockingSubscribe(...);
结果flowable，它被重新执行。如何使已经计算出的缓冲区中的值第二次出现并且预期结束？
结果证明解决方案非常简单。
然后每个订阅者都会收到大概的结果，等待执行结束。