A suggestion arose to add a wrapper of the couroutines in jp.co.soramitsu.iroha2.Iroha2Client into the reactor and/or reactive stream publisher (whichever is easier, with preference for the publisher).
fun subscribeToBlocks(from: Long, count: Int): Flux<VersionedBlockMessage> {
return subscribeToBlockStream(from, count).asFlux()
}
fun subscribeToBlocksAsPublisher(from: Long, count: Int): Publisher<VersionedBlockMessage> {
return subscribeToBlockStream(from, count).asPublisher();
}