diff --git a/docker/errors.py b/docker/errors.py
index 50423a26..eeeac579 100644
--- a/docker/errors.py
+++ b/docker/errors.py
@@ -144,6 +144,10 @@ class BuildError(Exception):
     pass
 
 
+class ImageLoadError(DockerException):
+    pass
+
+
 def create_unexpected_kwargs_error(name, kwargs):
     quoted_kwargs = ["'{}'".format(k) for k in sorted(kwargs)]
     text = ["{}() ".format(name)]
diff --git a/docker/models/images.py b/docker/models/images.py
index 891c565f..dcdeac98 100644
--- a/docker/models/images.py
+++ b/docker/models/images.py
@@ -3,7 +3,7 @@ import re
 import six
 
 from ..api import APIClient
-from ..errors import BuildError
+from ..errors import BuildError, ImageLoadError
 from ..utils.json_stream import json_stream
 from .resource import Collection, Model
 
@@ -241,13 +241,27 @@ class ImageCollection(Collection):
             data (binary): Image data to be loaded.
 
         Returns:
-            (generator): Progress output as JSON objects
+            (list of :py:class:`Image`): The images.
 
         Raises:
             :py:class:`docker.errors.APIError`
                 If the server returns an error.
         """
-        return self.client.api.load_image(data)
+        resp = self.client.api.load_image(data)
+        images = []
+        for chunk in resp:
+            if 'stream' in chunk:
+                match = re.search(
+                    r'(^Loaded image ID: |^Loaded image: )(.+)$',
+                    chunk['stream']
+                )
+                if match:
+                    image_id = match.group(2)
+                    images.append(image_id)
+            if 'error' in chunk:
+                raise ImageLoadError(chunk['error'])
+
+        return [self.get(i) for i in images]
 
     def pull(self, name, tag=None, **kwargs):
         """
diff --git a/tests/integration/models_images_test.py b/tests/integration/models_images_test.py
index 8f812d93..8840e15d 100644
--- a/tests/integration/models_images_test.py
+++ b/tests/integration/models_images_test.py
@@ -71,6 +71,11 @@ class ImageCollectionTest(BaseIntegrationTest):
         image = client.images.pull('alpine', tag='3.3')
         assert 'alpine:3.3' in image.attrs['RepoTags']
 
+    def test_load_error(self):
+        client = docker.from_env(version=TEST_API_VERSION)
+        with pytest.raises(docker.errors.ImageLoadError):
+            client.images.load('abc')
+
 
 class ImageTest(BaseIntegrationTest):