在Kotlin中使用Reactor的分页Gitlab API

implementation("io.projectreactor.kotlin:reactor-kotlin-extensions")
implementation("org.springframework.boot:spring-boot-starter-webflux")
implementation("org.springframework.boot:spring-boot-starter-web")
implementation("org.springframework.boot:spring-boot-starter-data-jpa")
implementation("org.springframework.boot:spring-boot-starter-data-rest")

import org.springframework.stereotype.Service
import org.springframework.web.reactive.function.client.WebClient
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

@Service
class GitlabService(private val webClient: WebClient) {

    fun getProjects(page: Int, pageSize: Int): Flux<Project> {
        return webClient.get()
            .uri("/projects?per_page={pageSize}&page={page}", pageSize, page)
            .retrieve()
            .bodyToFlux(Project::class.java)
    }

    fun getProjectById(id: Long): Mono<Project> {
        return webClient.get()
            .uri("/projects/{id}", id)
            .retrieve()
            .bodyToMono(Project::class.java)
    }
}

data class Project(val id: Long, val name: String, val description: String)

import org.springframework.web.bind.annotation.GetMapping
import org.springframework.web.bind.annotation.PathVariable
import org.springframework.web.bind.annotation.RequestMapping
import org.springframework.web.bind.annotation.RestController
import reactor.core.publisher.Flux
import reactor.core.publisher.Mono

@RestController
@RequestMapping("/api/gitlab")
class GitlabController(private val gitlabService: GitlabService) {

    @GetMapping("/projects")
    fun getProjects(): Flux<Project> {
        return gitlabService.getProjects(1, 10)
    }

    @GetMapping("/projects/{id}")
    fun getProjectById(@PathVariable id: Long): Mono<Project> {
        return gitlabService.getProjectById(id)
    }
}

import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.web.reactive.function.client.WebClient

@Configuration
class WebClientConfig {

    @Bean
    fun webClient(): WebClient {
        return WebClient.create("https://gitlab.example.com/api/v4")
    }
}