return quasarService.findByReceivedStatus(organizationId, receiverId)
.delayElements(Duration.ofSeconds(delay))
.cache()
.take(50)
.onBackpressureDrop()
.repeat(3) /// if repeat number not specified connection will keep long..
.parallel(50); //ParallelFlux
1条答案
按热度按时间roejwanj1#
您应该将TEXT_EVENT_STREAM_VALUE与Spring reactive一起使用,但是它的开销很大(CPU/内存太大)
理想情况下,Spring控制器应返回