Привет, ребята. Я разрабатываю API с webflux и kotlin. Мой вопрос прост, мне нужно манипулировать свойствами объекта Flux, который возвращает меня при использовании API, это объект, который причиняет мне боль
postId": 14,
"userId": 2,
"title": "voluptatem eligendi optio",
"comments": [
{
"email": "Janice@alda.io",
"body": "necessitatibus libero occaecati\nvero inventore iste assumenda veritatis\nasperiores non sit et quia omnis facere nemo explicabo\nodit quo nobis porro"
}
]
Это мой контроллер, который делает запрос и возвращает предыдущий JSON объект
fun getData(): Flux<Post> {
return apiService.fetchPosts()
}
Это код службы, с которой я использую API
@Service
class APIService {
fun fetchComments(postId:Int) =
fetch("posts/$postId/comments").bodyToFlux(Comment::class.java)
fun fetchPosts() =
fetch("/posts").bodyToFlux(Post::class.java)
fun fetch(path:String): WebClient.ResponseSpec {
val client = WebClient.create("http://jsonplaceholder.typicode.com/")
return client.get().uri(path).retrieve()
}
}
Спасибо