sdeleuze
06/06/2017, 10:01 PMrpalcolea
06/06/2017, 10:01 PMrpalcolea
06/06/2017, 10:01 PMsdeleuze
06/06/2017, 10:01 PMrpalcolea
06/06/2017, 10:01 PMsdeleuze
06/06/2017, 10:02 PMrpalcolea
06/06/2017, 10:36 PMrpalcolea
06/06/2017, 10:37 PMrpalcolea
06/06/2017, 10:38 PMvarpa89
06/07/2017, 6:35 AMfun GET(pattern: String, f: (ServerRequest) -> Mono<ServerResponse>) {
routes += RouterFunctions.route(RequestPredicates.GET(pattern), HandlerFunction { f(it) })
}
dariuszbacinski
06/07/2017, 7:17 AMdariuszbacinski
06/07/2017, 7:29 AMsdeleuze
06/07/2017, 7:54 AM(ServerRequest) -> Mono<ServerResponse>
but you can use Flux
for reading/writing the bodysdeleuze
06/07/2017, 7:55 AMsdeleuze
06/07/2017, 7:56 AMvarpa89
06/07/2017, 9:23 AMfun foo(): Flux<ByteArray> {
val client = WebClient.create("<https://byte-array-service>")
return client
.get()
.uri("/info")
.accept(MediaType.APPLICATION_OCTET_STREAM)
.exchange()
.flatMapMany {
r -> r.bodyToFlux(ByteArray::class.java)
}
}
In my handler I do this
fun handleFoo(req: ServerRequest) = myService
.foo()
.flatMap {
ok().body(BodyInserters.fromObject(it))
}
Compile is ok byt maybe I was wrong with BodyInserter. But my router does not compile
"/foo".nest {
GET("/", myHandler::handleFoo)
}
jasper
06/11/2017, 3:22 AMjasper
06/11/2017, 3:22 AMCzar
06/12/2017, 5:35 PM@Primary
. In some components KA is autowired, in others A does.
What the hell?
If I rewrite KA in Java, then everything works as expected.
All kotlin and java classes live in src/main/java
. Kotlin version is 1.1.1, I use jvm8.agomez
06/12/2017, 5:50 PM@Primary
at all and the reason why sometimes injects one or other is the name of the attribute/parameter where is injected?agomez
06/12/2017, 5:51 PMagomez
06/12/2017, 5:51 PMagomez
06/12/2017, 5:55 PMCzar
06/12/2017, 6:09 PM@Autowired A a;
Czar
06/12/2017, 6:10 PMagomez
06/12/2017, 6:12 PMagomez
06/12/2017, 6:13 PMagomez
06/12/2017, 6:14 PMCzar
06/12/2017, 6:20 PM