cubetiq/wsclient
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

Updated webclient and add readme

Browse Source
This commit is contained in:
Sambo Chea 2020-07-12 11:24:05 +07:00
parent a8b2346b16
commit d9444a5925
2 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
README.md Normal file
View File

@ -0,0 +1,2 @@
### WS Client for RSocket Client and Web Client

2
src/main/kotlin/com/cubetiqs/wsclient/WebClientStockClient.kt
View File

@ -3,7 +3,7 @@ package com.cubetiqs.wsclient
import org.springframework.web.reactive.function.client.WebClient import org.springframework.web.reactive.function.client.WebClient
import reactor.core.publisher.Flux import reactor.core.publisher.Flux
class WebClientStockClient(val webClient: WebClient) : StockClient { class WebClientStockClient(private val webClient: WebClient) : StockClient {
override fun priceFor(symbol: String): Flux<StockPrice> { override fun priceFor(symbol: String): Flux<StockPrice> {
return webClient.get() return webClient.get()
.uri("http://localhost:8080/stocks/{symbol}", symbol) .uri("http://localhost:8080/stocks/{symbol}", symbol)