nbari

@nickkuk Thanks for the example, any idea how to integrate [indicatif](https://crates.io/crates/indicatif)? I want to display the current progress. Is there a way to "do something" (`bar.inc(1);`) in every chunk from...

Thanks, I am using [this approach](https://stackoverflow.com/a/63368123/1135424), `inspect_ok` does the trick: ``` use futures::stream::TryStreamExt; use tokio_util::codec::{BytesCodec, FramedRead}; let stream = FramedRead::new(file, BytesCodec::new()) .inspect_ok(|chunk| { // do X with chunk... }); let...

Hi @nickkuk, I am currently working on it, indeed I am stuck with this, https://stackoverflow.com/q/63374041/1135424, any helps is pretty much appreciated. let stream = if let Some(mut tx) = sender...

@nickkuk many thanks for the examples, I was indeed dealing with the `if/ else` until found I could do: let stream = async_stream::stream! { ... };

Hi @nickkuk I found interesting this [example](https://stackoverflow.com/a/63374116/1135424): ```rust use tokio::sync::mpsc; use futures::future::Either; fn upload(file: String, sender: Option

Hi @nickkuk many thanks for the explanation and your time on this, taking advantage of the thread, I have one last question regarding this topic, probably too basic but hope...

@nickkuk many thanks for the examples and sharing the knowledge, I highly appreciate it :-)

@HannanSolo Nice hope they accept it, please change title: https://github.com/Homebrew/homebrew-core/pull/33487#issuecomment-433967843 Also, note that lates version is `1.1.2` also check https://jenkins.brew.sh/job/Homebrew%20Core%20Pull%20Requests/32587/version=mojave/testReport/brew-test-bot/mojave/audit_www___online___new_formula/

@HannanSolo you could fix it and when is time just push it :-)

Hi @meeuw, option `\G` works fine for me, I was just wondering if there was an option to behave like the mysql client. Probably adding an option in the configuration...