Hello All! Had a question related to gRPC server ...

# flow

[Vinay Pothnis]

Hello All!

Had a question related to gRPC server streaming + flow.
Supposed I have something like this:

override fun listThings(request: SomeRequest): Flow<Thing> = flow {
        // Would like to emit() a `Thing` based on messages received on a subscription
        // for example, in the `onMessage` method of a message listener
    }

I would like to emit() a response/message on the gRPC stream - but I would like to drive that based on messages from a subscription.
How do I tie the onMessage on the message listener and this gRPC handler together?