У меня есть сервер Vertx, который отправляет на события для всех стримеров информацию.
Использование консоли, которая работает так, как желает.val webClientOpt = WebClientOptions()
.setKeepAlive(true)
.setUserAgent("Client/2.0")
.setFollowRedirects(true)
.setShared(true)
< /code>
Client Call < /p>
client
.get(port, host, UriTemplate.of(s"${path}event-bus/"))
.putHeader("content-type", "application/json")
.bearerTokenAuthentication(UserBuffer.loggedInUser().jwtToken())
.as(BodyCodec.pipe(writeBuffer)).send()
< /code>
Теперь writebuffer и читатель < /p>
val writeBuffer = ReactiveWriteStream.writeStream[Buffer](vertx)
val readStream = ReactiveReadStream.readStream[Buffer]()
< /code>
также материал, чтобы получить данные < /p>
readStream.handler(j => {
println("CONSUMING!!!!")
println(j.toString("UTF-8"))
})
writeBuffer.subscribe(readStream)
< /code>
Я знаю, что должен использовать BodyCodec.pipe, но я думаю, что вот моя проблема. Я думаю, я не использую это правильно.
Подробнее здесь: https://stackoverflow.com/questions/797 ... d-messages
