| 21 Jan 2020 |
| 14:51:59 |  João Oliveira | então é join tb |
| 14:52:16 | João Oliveira | join nos 2 futures e .await |
| 14:52:39 |  Cauê Baasch de Souza | achei que não se usava mais essa crate de futures |
| 14:52:44 | João Oliveira | usa usa |
| 14:52:42 | João Oliveira | https://docs.rs/futures/0.3.1/futures/future/fn.join.html |
| 14:52:59 | João Oliveira | continua tendo StreamExt, FutureExt, etc |
| 14:53:30 |  Brúnn Timbrmaðr | Oq foi pra std é só a trait Future mais basiquinha |
| 14:53:45 | Brúnn Timbrmaðr | E o que precisava pra definir ela |
| 14:53:55 | Brúnn Timbrmaðr | Como Poll e Context |
| 14:54:16 | João Oliveira | isso |
| 14:54:55 | Cauê Baasch de Souza | mas async-std usa essa crate futures? |
| 14:55:05 | Cauê Baasch de Souza | nunca vi ser necessário |
| 14:55:14 |  Rodolfo | In reply to João Oliveira
vc quer processar 2 streams concorrentemente, é isso? Isso, exatamente |
| 14:56:28 | Joã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 | João Oliveira | senão tem macro select! |
| 14:56:46 | João Oliveira | https://docs.rs/futures/0.3.1/futures/macro.select.html |
| 14:59:37 | Rodolfo | 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 | João Oliveira | qual é a origem do stream? |
| 15:00:36 | João Oliveira | TcpStream implementa Stream, Bounded e Unbounded Channel's implementam stream |
| 15:03:42 | Rodolfo | In reply to João Oliveira
qual é a origem do stream? Crio uma consumer no Kafka com a rdkafka |
| 15:05:04 | João Oliveira | https://docs.rs/rdkafka/0.23.1/rdkafka/consumer/stream_consumer/struct.MessageStream.html#impl-TryStream |
| 15:04:37 | Rodolfo | Vou tentar o select e o join |
| 15:05:08 | João Oliveira | tem TryStream |
| 15:05:41 | Rodolfo | Faz sentido só o await travar uma porque o stream não termina, aí usando o join ajuda |
| 15:06:07 | Brú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 | Cauê Baasch de Souza | mesmo que seja só reexport, acho bem mais ergonômico |
| 15:07:16 | João Oliveira | Tokio só re-implementa AsyncRead e AsyncWrite |
| 15:07:54 | Joã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 |  Nilton OS | https://locka99.gitbooks.io/a-guide-to-porting-c-to-rust/content/ |
| 15:24:18 |  Julio 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... |
