Browse Source

Introduce HttpServiceProxyFactory#createClient Kotlin extension

Closes gh-29942
pull/29946/head
Sébastien Deleuze 3 years ago
parent
commit
a2a676241c
  1. 26
      spring-webflux/src/main/kotlin/org/springframework/web/service/invoker/HttpServiceProxyFactoryExtensions.kt
  2. 3
      spring-webflux/src/test/kotlin/org/springframework/web/reactive/function/client/support/KotlinWebClientHttpServiceProxyTests.kt
  3. 40
      spring-webflux/src/test/kotlin/org/springframework/web/service/invoker/HttpServiceProxyFactoryExtensionsTests.kt

26
spring-webflux/src/main/kotlin/org/springframework/web/service/invoker/HttpServiceProxyFactoryExtensions.kt

@ -0,0 +1,26 @@ @@ -0,0 +1,26 @@
/*
* Copyright 2002-2023 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.web.service.invoker
/**
* Extension for [HttpServiceProxyFactory.createClient] providing a `createClient<Foo>()` variant.
*
* @author Sebastien Deleuze
* @since 6.0.5
*/
inline fun <reified T : Any> HttpServiceProxyFactory.createClient(): T =
createClient(T::class.java)

3
spring-webflux/src/test/kotlin/org/springframework/web/reactive/function/client/support/KotlinWebClientHttpServiceProxyTests.kt

@ -28,6 +28,7 @@ import org.springframework.web.reactive.function.client.ExchangeFunction @@ -28,6 +28,7 @@ import org.springframework.web.reactive.function.client.ExchangeFunction
import org.springframework.web.reactive.function.client.WebClient
import org.springframework.web.service.annotation.GetExchange
import org.springframework.web.service.invoker.HttpServiceProxyFactory
import org.springframework.web.service.invoker.createClient
import reactor.core.publisher.Mono
import reactor.test.StepVerifier
import java.time.Duration
@ -130,7 +131,7 @@ class KotlinWebClientHttpServiceProxyTests { @@ -130,7 +131,7 @@ class KotlinWebClientHttpServiceProxyTests {
return HttpServiceProxyFactory.builder()
.clientAdapter(WebClientAdapter.forClient(webClient))
.build()
.createClient(TestHttpService::class.java)
.createClient()
}
private fun prepareResponse(consumer: Consumer<MockResponse>) {

40
spring-webflux/src/test/kotlin/org/springframework/web/service/invoker/HttpServiceProxyFactoryExtensionsTests.kt

@ -0,0 +1,40 @@ @@ -0,0 +1,40 @@
/*
* Copyright 2002-2023 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.springframework.web.service.invoker
import io.mockk.every
import io.mockk.mockk
import io.mockk.verify
import org.junit.jupiter.api.Test
/**
* Tests for [HttpServiceProxyFactory] Kotlin extensions.
*
* @author Sebastien Deleuze
*/
class HttpServiceProxyFactoryExtensionsTests {
private val proxyFactory = mockk<HttpServiceProxyFactory>()
@Test
fun `createClient extension`() {
every { proxyFactory.createClient(String::class.java) } returns ""
proxyFactory.createClient<String>()
verify { proxyFactory.createClient(String::class.java) }
}
}
Loading…
Cancel
Save