Как настроить проверку POJO в реактивном микронавтике

Question

С помощью micronaut.io как настроить POJO-проверку реактивного содержимого тела HTTP? Это работает для синхронного случая, а именно:

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

но это не работает в асинхронном случае:

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

Спасибо

Answer 1

Обходной путь, который я нашел, состоит в том, чтобы объявить метод в контроллере, который запускает проверку, и использовать его следующим образом:

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

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

но было бы неплохо, если бы фреймворк мог сделать это для меня..