如何在不阻塞的情况下从Flux获取列表？

Question

我有一个存储库，它返回一个流量，并希望将结果设置为另一个需要列表的对象。有没有其他方法可以在不阻塞的情况下以列表的形式获取结果？

这座大楼正在运转，但需要很长时间。

public class FluxToListTest {

    @Autowired PostRepository postRepository;

    public void setUserPosts(User user) {
      user.setPostList(postRepository.findAllByOrderId(user.getId()).collectList().block());
  }
}


interface PostRepository {

    Flux<Post> findAllByOrderId(final UUID userId);
}


@Data
class User {
  UUID id;
  List<Post> postList;
}


class Post {
    UUID id;
    String content;
}

Answer 1

简而言之，不需要。您不需要从Flux中提取List。如果你已经开始使用Reactor流——坚持下去。

请尝试以下代码：

public void setUserPosts(User user) {
    postRepository.findAllByOrderId(user.getId())
        .collectList()
        .doOnNext(user::setPostList)// (1)
        .subscribe();               // (2) 
}  

1. 如果您设置的操作是阻塞，请使用发布/订阅以避免阻塞所有流。
2. 它开始你的流执行