Update subunit-ls.

2 files changed, 16 insertions, 1 deletions

diff --git a/python/subunit/filters.py b/python/subunit/filters.py
index 208bd8b..be3b6b8 100644
--- a/python/subunit/filters.py
+++ b/python/subunit/filters.py
@@ -102,7 +102,7 @@ def filter_by_result(result_factory, output_path, passthrough, forward,
     :param input_stream: The source of subunit input.  Defaults to
         ``sys.stdin``.
     :param protocol_version: The subunit protocol version to expect.
-    :return: A test result with the resultts of the run.
+    :return: A test result with the results of the run.
     """
     if passthrough:
         passthrough_stream = sys.stdout
diff --git a/python/subunit/test_results.py b/python/subunit/test_results.py
index 91c9bbd..7d60962 100644
--- a/python/subunit/test_results.py
+++ b/python/subunit/test_results.py
@@ -25,8 +25,10 @@ from testtools.content import (
     text_content,
     TracebackContent,
     )
+from testtools import StreamResult
 
 from subunit import iso8601
+import subunit
 
 
 # NOT a TestResult, because we are implementing the interface, not inheriting
@@ -676,3 +678,16 @@ class CsvResult(TestByTestResult):
     def startTestRun(self):
         super(CsvResult, self).startTestRun()
         self._write_row(['test', 'status', 'start_time', 'stop_time'])
+
+
+class CatFiles(StreamResult):
+    """Cat file attachments received to a stream."""
+
+    def __init__(self, byte_stream):
+        self.stream = subunit.make_stream_binary(byte_stream)
+
+    def status(self, test_id=None, test_status=None, test_tags=None,
+        runnable=True, file_name=None, file_bytes=None, eof=False,
+        mime_type=None, route_code=None, timestamp=None):
+        if file_name is not None:
+            self.stream.write(file_bytes)