improve Read implementation

.circleci/config.yml

@@ -49,9 +49,12 @@ jobs:
             apt list --installed      >> /tmp/build-dep
       - restore_cache:
           key: cache-cargo-target-{{ .Environment.CIRCLE_JOB }}-{{ .Environment.CIRCLECI_CACHE_VERSION }}-{{ checksum "/tmp/build-dep" }}
+      - run:
+          name: Install rustfmt
+          command: rustup component add rustfmt-preview
       - run:
           name: Checking source code style
-          command: cargo fmt -- --write-mode "diff"
+          command: cargo fmt -- --check
       - run:
           name: Build project
           command: |

examples/attach-container.rs

@@ -1,7 +1,7 @@
 extern crate dockworker;
 extern crate hyper;
 
-use dockworker::{ContainerCreateOptions, ContainerHostConfig, Docker, container::AttachContainer};
+use dockworker::{container::AttachContainer, ContainerCreateOptions, ContainerHostConfig, Docker};
 use std::io::{BufRead, BufReader};
 
 fn main() {

examples/build-image.rs

@@ -1,11 +1,11 @@
 extern crate dockworker;
 extern crate tar;
 
+use dockworker::{ContainerBuildOptions, Docker};
+use std::fs::File;
 use std::io::{BufRead, BufReader, Write};
 use std::path::Path;
-use std::fs::File;
 use tar::Builder;
-use dockworker::{ContainerBuildOptions, Docker};
 
 fn main() {
     {
@@ -14,7 +14,8 @@ fn main() {
             .write_all(
                 r#"FROM alpine:edge
         RUN echo Hi mum
-        "#.as_bytes(),
+        "#
+                .as_bytes(),
             )
             .unwrap();
     }

examples/containers.rs

@@ -1,6 +1,6 @@
 extern crate dockworker;
 
-use dockworker::{Docker, container::ContainerFilters};
+use dockworker::{container::ContainerFilters, Docker};
 
 fn main() {
     let docker = Docker::connect_with_defaults().unwrap();

examples/history.rs

@@ -8,9 +8,11 @@ fn main() {
 
     println!("History:");
     match history {
-        Ok(changes) => for change in changes {
-            println!("{:#?}", change);
-        },
+        Ok(changes) => {
+            for change in changes {
+                println!("{:#?}", change);
+            }
+        }
         Err(e) => {
             println!("Error {}", e);
         }

examples/prune-image.rs

@@ -1,6 +1,6 @@
 extern crate dockworker;
 
-use dockworker::{Docker, container::ContainerFilters};
+use dockworker::{container::ContainerFilters, Docker};
 
 fn main() {
     let docker = Docker::connect_with_defaults().unwrap();

examples/push.rs

@@ -1,7 +1,10 @@
 extern crate dockworker;
 extern crate hyper;
 
-use dockworker::{Docker, credentials::{Credential, UserPassword}};
+use dockworker::{
+    credentials::{Credential, UserPassword},
+    Docker,
+};
 
 fn main() {
     let mut docker = Docker::connect_with_defaults().unwrap();

src/container.rs

@@ -1,11 +1,11 @@
 use byteorder::{BigEndian, ReadBytesExt};
+use errors::Result;
 use hyper_client::Response;
 use std;
+use std::cell::{Ref, RefCell, RefMut};
 use std::collections::HashMap;
 use std::io::{self, Read};
 use std::rc::Rc;
-use std::cell::{Ref, RefCell, RefMut};
-use errors::Result;
 
 #[derive(Debug, Clone, Serialize, Deserialize)]
 #[allow(non_snake_case)]

src/credentials.rs

@@ -1,9 +1,8 @@
+use header::XRegistryAuth;
 ///! Access credentials for accessing any docker daemon endpoints
 ///!
 ///! Currently, any values of these types are only used for `/images/{name}/push` api.
-
 use serde_json;
-use header::XRegistryAuth;
 use system::AuthToken;
 
 /// Access credential