Братья мои, можно ещё немножко подоставать вас с gRPC?

Question

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья

Братья мои, можно ещё немножко подоставать вас с gRPC?

async fn stream_messages(
&self,
request: Request<Streaming<StreamRequest>>,
) -> Result<Response<Self::StreamMessagesStream>, Status> {
let (mut tx, rx) = mpsc::channel(4);

tokio::spawn(async move {
let mut stream = request.into_inner();

while let Some(message) = stream.message().await.unwrap() {
let response = StreamResponse {
message: format!("Received: {}", message.data),
};

tx.send(Ok(response)).await.unwrap();
}
});

Ok(Response::new(rx))
}

Отрезок из стандартного примера если что (ну вернее его скопировал Bing Ai из него и мне выдал) я не совсем понимаю, какое действие происходит в конце, и куда уходит return? Типо собирается какой то поток, который отправляет респонзы из rx на клиент?

#backend #embedded #programming #russian #rust

0

07.11.2023

10 ответов

35 просмотров

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья Автор вопроса

Nail Khanipov
return Ok(Response::new(rx)); == Ok(Response::new(...

Да, я понял, я просто не совсем понимаю, куда он возвращает значение, и что из себя значение представляет

0

07.11.2023

Nail Khanipov

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья
Да, я понял, я просто не совсем понимаю, куда он в...

а это вообще работает? :D

0

07.11.2023

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья Автор вопроса

Nail Khanipov
а это вообще работает? :D

Да

0

07.11.2023

red75prime

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья
Да, я понял, я просто не совсем понимаю, куда он в...

Не пониманию, что именно непонятно. Значение из метода возвращается туда, где этот метод был вызван. Непонятно откуда этот метод вызывается? В vscode есть "Go to references"

0

07.11.2023

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья Автор вопроса

red75prime
Не пониманию, что именно непонятно. Значение из ме...

Пытаюсь понять механизм, по которому в tonic работают стримы сообщений, чтобы не копипастить в тупую из примеров, а быть в состоянии осмысленно самостоятельно реализовывать что мне нужно

0

07.11.2023

red75prime

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья
Пытаюсь понять механизм, по которому в tonic работ...

Ну да, посмотреть где этот stream_messages вызывается и что там делают с возвращённым rx

0

07.11.2023

кiтя aka. Танечка, aka. Стэф, aka. Мамочка, aka. Виктория, aka. Дарья, aka. Грудь, aka. Лавашик, aka. Не Илья Автор вопроса

red75prime
Ну да, посмотреть где этот stream_messages вызывае...

Там код из кодгена, по нему не работают переходы

0

07.11.2023