将Flux;文档>转换为Flux<对象>或列表<对象>

2022-04-06 00:00:00 java spring-webflux project-reactor bson

我有一个

对象
class Employee {

    private String salary;
    private String empId;
    private String departmentId;
    private String status;
} 

和一个返回Flux<;Document&>的方法,Document的类型为org.bson.Document,示例

[
    {
        "empId": "B123",
        "salary": "1000",
        "departmentId": "winna",
        "status": "START"
    },
    {
        "empId": "A123",
        "salary": "2000",
        "departmentId": "dinna",
        "status": "COMPLETED"
    }
] 

如何在Java中将Flux<;文档&>转换为Flux<;员工&>或列出<;员工&>?


解决方案

我正在使用这个。它运行得非常好。studentService.getAll()返回Flux<Student>使用map I可以转换为Flux<String>。您需要考虑@Ikatiforis的答案。

在您的情况下,以下操作应该有效

documentFlux.map(d-> {
            Employee e = new Employee();
            //set values
            return e;
        });

相关文章