并不是所有的數(shù)據(jù)都要待在內(nèi)存里,Reactor
已經(jīng)開(kāi)始整合(可選依賴)Java Chronicle。
return Streams.merge(
userService.filteredFind("Rick"),
userService.filteredFind("Morty")
)
.buffer()
.retryWhen( errors ->
errors
.zipWith(Streams.range(1,3), t -> t.getT2())
.flatMap( tries -> Streams.timer(tries) )
)
.consume(System.out::println);
表 15,安全的持久化信號(hào)
http://wiki.jikexueyuan.com/project/reactor-2.0/images/39.png" alt="" />