search

vert-x3 / vertx-lang-kotlin

Vert.x for Kotlin
Apache License 2.0
296 stars 68 forks source link

Flow support #152

Closed Globegitter closed 1 year ago

Globegitter commented 5 years ago

It would be nice to have have support for Kotlin's Flow wherever fitting, e.g. for streaming results from postgres. It has been promoted to sable recently: https://github.com/Kotlin/kotlinx.coroutines/releases/tag/1.3.0 and we are already making use of it in our applications, so it would be great if we could integrate vertx easily into that.

asad-awadia commented 4 years ago

@Globegitter what would it look like? Like flow emit the eventbus messages?

ylemoigne commented 4 years ago

On my side, I would like bridge/operator to convert a ReadStream to a Flow and conversion from Flow to WriteStream.

tsegismont commented 1 year ago

@Globegitter you can convert a ReadStream to a channel and then use consumeAsFlow