Reactive db 不使用 application/stream+json 获取最新记录

如何解决Reactive db 不使用 application/stream+json 获取最新记录

我正在尝试使用响应式 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","A");
        List<Author> list = new ArrayList<Author>();
        list.add(author);
        list.add(author1);
        Flux<Author> flux = repository.saveAll(list);
        flux.subscribe();
        return flux;
    }

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

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