spring - 反应式数据库未使用 application/stream+json 获取最新记录

Question

我正在尝试使用响应式 mongodb 来获取数据流application/stream+json。

控制器 ：

@GetMapping(value = "/findAll", produces = MediaType.APPLICATION_STREAM_JSON_VALUE)  
    public Flux<Author> findAll() { 
        Flux<Author> flux = repository.findAll();
        return flux.delayElements(Duration.ofMillis(500));
    }

@GetMapping("/insertAuthor")
public Flux<Author> insertAuthor() {
        Author author= new Author("Some Author name", "Book name", new Date(), "A");
        Author author1 = new Author("Some other Author name", "Another Book name", new Date(), "A");
        List<Author> list = new ArrayList<Author>();
        list.add(author);
        list.add(author1);
        Flux<Author> flux = repository.saveAll(list);
        flux.subscribe();
        return flux;
    }

因此，在插入一些作者后，能够以 500 毫秒的延迟在浏览器上获取数据。但是假设我们已经插入了 100 个作者并调用 findAll 端点，这将需要大约 50 秒才能在浏览器上显示所有作者。如果我再插入几个作者，findAll 不会显示它，尽管它仍在处理现有记录。

当数据流显示在浏览器上时，有什么方法可以从反应式 mongo 存储库中获取最近插入的记录。