Stream 数据持久化

并不是所有的数据都要待在内存里，Reactor已经开始整合（可选依赖）Java Chronicle。

  1. return Streams.merge(
  2.   userService.filteredFind("Rick"),
  3.   userService.filteredFind("Morty")
  4. )
  5. .buffer()
  6. .retryWhen( errors ->
  7.   errors
  8.   .zipWith(Streams.range(1,3), t -> t.getT2())
  9.   .flatMap( tries -> Streams.timer(tries) )
  10. )
  11. .consume(System.out::println);
表15，安全的持久化信号
功能 API 或 工厂方法作用
Stream.onOverflowBuffer(CompletableQueue)
IOStreams.persistentMapReader()
IOStreams.persistentMap()