java中flux.subscribe如何实现wait/notify

Question

我刚开始使用 Java 进行函数式编程，遇到了一些困难。 我正在编写一种方法来建立与数据库的反应性会话并将通量对象返回给调用者。 然后，调用者将订阅此通量并相应地获取结果。 试图模仿这个例子here

我有的是

return  Flux.usingWhen(
         Mono.just(getDataStore().getRxSession()),
         session -> Flux.from(session.run(query).records()),
         RxSession::close);

然后一个不同的函数订阅这个通量

Flux<Record> rflux =  query.sub();
rflux.takeUntil(//Implement wait and notifier here).subscribe(//notify here);