Support multiple messages per chunk in streaming image pull (softprop…

…s#154)
Metaswitch · Feb 25, 2019 · ad95d93 · ad95d93
1 parent 0ae953c
commit ad95d93
Showing 1 changed file with 9 additions and 1 deletion.
diff --git a/src/lib.rs b/src/lib.rs
@@ -197,7 +197,15 @@ impl<'a> Images<'a> {
         self.docker
             .stream_post::<Body>(&path.join("?"), None)
             // todo: give this a proper enum type
-            .and_then(|r| serde_json::from_slice::<Value>(&r[..]).map_err(Error::from))
+            .map(|r| {
+                futures::stream::iter_result(
+                    serde_json::Deserializer::from_slice(&r[..])
+                        .into_iter::<Value>()
+                        .collect::<Vec<_>>(),
+                )
+                .map_err(Error::from)
+            })
+            .flatten()
     }
 
     /// exports a collection of named images,