mongodb - Jave webflux 处理带有 id 的字符串响应

Question

我有一个响应式 API，它接收以下字符串（下图）。我想处理这些 ID 并对我的 MongoDB 执行搜索查询并返回一个带有我的模型的 Flux（填充数据库中存在的 ID）

我到目前为止得到的代码是：

public Mono<ServerResponse> findAllSpeakersBySessionId(ServerRequest request) {
    Flux<String> listWithIds = request.bodyToFlux(String.class);
    return ServerResponse.ok()
            .contentType(MediaType.APPLICATION_JSON)
            .body(speakerService.findAllByIds(listWithIds), String.class);
}


public Flux<Speaker> findAllByIds(Flux<String> speaker_Ids) {
    return this._speakerRepository.findAllById(speaker_Ids);
}

我是这种反应式编程的新手，并试图理解它。我将如何处理这个字符串响应，以便它查找这些 ID 并返回一个 Flux

扬声器级

@Getter
@Setter
@NoArgsConstructor
@AllArgsConstructor
public class Speaker {
    @Id
    private String speaker_id;
    @NotNull
    private String name;
    private String skills;
    private String company;
    private String biography;
    private String specialisation;
    private List<String> session_Ids;
}