Skip to content

[LAOS] Add coroutine wrapper for Iroha2Client as reactive stream publisher #365

@appetrosyan

Description

@appetrosyan

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();
}

Metadata

Metadata

Assignees

No one assigned

    Labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions