tangent128/webmetro
1
0
Fork 0
Code Issues 1 Pull requests Releases Packages Wiki Activity

Fix webmetro send not exiting when stdin ends.

Browse source
This commit is contained in:
Tangent 128 2018-10-21 02:22:46 -04:00
parent b64e3f4bac
commit 26930b07e0
2 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/commands/filter.rs
View file

@ -38,7 +38,7 @@ pub fn run(args: &ArgMatches) -> Result<(), WebmetroError> {
chunk_stream = Box::new(chunk_stream.throttle()); chunk_stream = Box::new(chunk_stream.throttle());
} }
Runtime::new().unwrap().block_on_all(chunk_stream.for_each(|chunk| { Runtime::new().unwrap().block_on(chunk_stream.for_each(|chunk| {
io::stdout().write_all(chunk.as_ref()).map_err(WebmetroError::IoError) io::stdout().write_all(chunk.as_ref()).map_err(WebmetroError::IoError)
})) }))
} }

2
src/commands/send.rs
View file

@ -72,5 +72,5 @@ pub fn run(args: &ArgMatches) -> Result<(), WebmetroError> {
}) })
.map_err(WebmetroError::from_err); .map_err(WebmetroError::from_err);
Runtime::new().unwrap().block_on_all(future) Runtime::new().unwrap().block_on(future)
} }