!TTseFeHXzHzpLDomvN:matrix.org

#rust-br

773 Members
Brazilian community on Telegram: https://t.me/rustlangbr36 Servers

Load older messages


Timestamp Message
21 Jan 2020
14:51:59@telegram_15263090:t2bot.ioJoão Oliveiraentão é join tb
14:52:16@telegram_15263090:t2bot.ioJoão Oliveirajoin nos 2 futures e .await
14:52:39@telegram_61407387:t2bot.ioCauê Baasch de Souzaachei que não se usava mais essa crate de futures
14:52:44@telegram_15263090:t2bot.ioJoão Oliveirausa usa
14:52:42@telegram_15263090:t2bot.ioJoão Oliveira https://docs.rs/futures/0.3.1/futures/future/fn.join.html
14:52:59@telegram_15263090:t2bot.ioJoão Oliveiracontinua tendo StreamExt, FutureExt, etc
14:53:30@telegram_109462432:t2bot.ioBrúnn TimbrmaðrOq foi pra std é só a trait Future mais basiquinha
14:53:45@telegram_109462432:t2bot.ioBrúnn TimbrmaðrE o que precisava pra definir ela
14:53:55@telegram_109462432:t2bot.ioBrúnn TimbrmaðrComo Poll e Context
14:54:16@telegram_15263090:t2bot.ioJoão Oliveiraisso
14:54:55@telegram_61407387:t2bot.ioCauê Baasch de Souzamas async-std usa essa crate futures?
14:55:05@telegram_61407387:t2bot.ioCauê Baasch de Souzanunca vi ser necessário
14:55:14@telegram_164824597:t2bot.ioRodolfo
In reply to João Oliveira
vc quer processar 2 streams concorrentemente, é isso?
Isso, exatamente
14:56:28@telegram_15263090:t2bot.ioJoão Oliveira
In reply to João Oliveira
https://docs.rs/futures/0.3.1/futures/stream/fn.select.html
se for Stream e tiverem o mesmo associated type, pode usar esse select
14:56:34@telegram_15263090:t2bot.ioJoão Oliveirasenão tem macro select!
14:56:46@telegram_15263090:t2bot.ioJoão Oliveira https://docs.rs/futures/0.3.1/futures/macro.select.html
14:59:37@telegram_164824597:t2bot.ioRodolfo
In reply to João Oliveira
caso de @rodolfoaraujo é Stream certo?
Tenho que ver exatamente, mas acho que posso retornar as streams pra usar elas
15:00:13@telegram_15263090:t2bot.ioJoão Oliveiraqual é a origem do stream?
15:00:36@telegram_15263090:t2bot.ioJoão OliveiraTcpStream implementa Stream, Bounded e Unbounded Channel's implementam stream
15:03:42@telegram_164824597:t2bot.ioRodolfo
In reply to João Oliveira
qual é a origem do stream?
Crio uma consumer no Kafka com a rdkafka
15:05:04@telegram_15263090:t2bot.ioJoão Oliveira https://docs.rs/rdkafka/0.23.1/rdkafka/consumer/stream_consumer/struct.MessageStream.html#impl-TryStream
15:04:37@telegram_164824597:t2bot.ioRodolfoVou tentar o select e o join
15:05:08@telegram_15263090:t2bot.ioJoão Oliveiratem TryStream
15:05:41@telegram_164824597:t2bot.ioRodolfoFaz sentido só o await travar uma porque o stream não termina, aí usando o join ajuda
15:06:07@telegram_109462432:t2bot.ioBrúnn Timbrmaðr
In reply to Cauê Baasch de Souza
mas async-std usa essa crate futures?
Eu acho que eles reimplementam as coisas por conta
15:06:50@telegram_61407387:t2bot.ioCauê Baasch de Souzamesmo que seja só reexport, acho bem mais ergonômico
15:07:16@telegram_15263090:t2bot.ioJoão OliveiraTokio só re-implementa AsyncRead e AsyncWrite
15:07:54@telegram_15263090:t2bot.ioJoão Oliveira
In reply to Rodolfo
Faz sentido só o await travar uma porque o stream não termina, aí usando o join ajuda
pra rodar no select! tem de transformar TryStream em Stream: https://docs.rs/futures/0.3.1/futures/stream/trait.TryStreamExt.html#method.into_stream
15:19:27@telegram_75440030:t2bot.ioNilton OS https://locka99.gitbooks.io/a-guide-to-porting-c-to-rust/content/
15:24:18@telegram_115826843:t2bot.ioJulio Biason
In reply to André Zanellato
demorei demais pra entender essa mensagem hauahauaha
Eu tive que fazer .unwrap_or("") pra poder continuar lendo as mensagens do grupo...

There are no newer messages yet.


Back to Room List