micronaut - Howto setup POJO validation in reactive micronaut

Question

With micronaut.io, how do I setup POJO validation of reactive HTTP body content? It works for the syncronous case, ie:

@Post("/sync/{id}")
HttpResponse createSync(String id, @Body @Valid SomePojo pojo) {
    ...
}

but it doesn't work in the async case:

@Post("/async/{id}")
Single<HttpResponse> createAsync(String id, @Body @Valid Single<SomePojo> pojoProducer) {
    ...
}

Thanks

Answer 1

我发现的解决方法是在控制器中声明一个触发验证的方法并以这种方式使用它：

    pojoProducer
        .map(pojo -> validate(pojo))
        ...

public <T> T validate(@Valid T t) {
    return t;
}

但如果框架可以为我做这将是很好的..