From ad95d93204cc84cc4648a1defac786db3ddd8582 Mon Sep 17 00:00:00 2001 From: Austin Brown Date: Mon, 25 Feb 2019 23:26:36 +0900 Subject: Support multiple messages per chunk in streaming image pull (#154) --- src/lib.rs | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/lib.rs b/src/lib.rs index 7d7283f..e733440 100644 --- a/src/lib.rs +++ b/src/lib.rs @@ -197,7 +197,15 @@ impl<'a> Images<'a> { self.docker .stream_post::(&path.join("?"), None) // todo: give this a proper enum type - .and_then(|r| serde_json::from_slice::(&r[..]).map_err(Error::from)) + .map(|r| { + futures::stream::iter_result( + serde_json::Deserializer::from_slice(&r[..]) + .into_iter::() + .collect::>(), + ) + .map_err(Error::from) + }) + .flatten() } /// exports a collection of named images, -- cgit v1.2.3