Ребят подскажите. Есть grpc-stream, который читает реактивную бд через find().publisher.asFlow()

Question

Ребят подскажите. Есть grpc-stream, который читает реактивную бд через find().publisher.asFlow()

нужно данные, которые он прочитал и собирается отдать сохранить в другой таблице. Для этого создаю Channel, в которого делаю send() в onEach { } того flow, который из бд. Дальше пишу в бд реактивно channel.receiveAsFlow().asFlux(). Как сделать так, что бы в случае если запись в бд свалилась по любым причинам flow, который читает так же развалился бы и grpc-streaming закончился?

#kotlin #programming #russian

0

01.06.2022

1 ответов

21 просмотр

Alexander Nozik · Accepted Answer

Во-первых, если не надо явно делать промежуточный канал, не делайте, просто мапьте один flow в другой. Тогда ваша проблема будет решена автоматически. Если нет, то вам надо повесить реакцию на закрытие вашего приемника и закрыть скоуп, в котором получаются события в это реакции.

169 похожих чатов

Ребят подскажите. Есть grpc-stream, который читает реактивную бд через find().publisher.asFlow()

1 ответов

Похожие вопросы