fun.kt

suspend fun getProducts(...): ReceiveChannel<ResultPage<Product>> = GlobalScope.produce {
    var requestUrl: String? = "/api/rest/v1/products"
    var firstRequest = true

    do {
        val response = httpClient.get<ResultPage<Product>> {
            url(requestUrl!!)
            header("Authorization", "Bearer ${token.accessToken}")
            if (firstRequest) {
                contentType(ContentType.Application.Json)
                parameter("search", objectMapper.writeValueAsString(search))
                params.forEach { k, v -> parameter(k, v) }
                firstRequest = false
            }
        }
        send(response)
        requestUrl = response.links.next?.href
    } while (requestUrl != null)
}