Add test of stream decompression speed

Author: sergey-dryabzhinsky

tests/test_decompress.py

@@ -11,7 +11,7 @@ def test_decompression_null(self):
         else:
             DATA = b''
         self.assertRaises(zstd.Error, zstd.uncompress, zstd.compress(DATA)+b' ')
-        
+
     def test_decompression_streamed(self):
         #log.info('cwd: %s' % os.getcwd())
         f = open("tests/test_data/facebook.ico.zst","rb")

tests/test_speed.py

@@ -19,9 +19,9 @@ def test_compression_speed(self):
             cdata = zstd.compress(tDATA)
             sum+=l
 
-        log.info("Compression speed average =%6f Mb/sec" % (1.0*sum/1024/1024/wait,))
+        log.info("Compression speed average = %6f Mb/sec" % (1.0*sum/1024/1024/wait,))
 
-    def test_decompression_speed(self):
+    def test_decompression_block_speed(self):
         wait = 30
         log.info("\nWait %d seconds..." % wait)
         sum = 0
@@ -32,7 +32,24 @@ def test_decompression_speed(self):
             data = zstd.decompress(cdata)
             sum+=l
 
-        log.info("Decompression speed average =%6f Mb/sec" % (1.0*sum/1024/1024/wait,))
+        log.info("Decompression of block data speed average = %6f Mb/sec" % (1.0*sum/1024/1024/wait,))
+
+    def test_decompression_stream_speed(self):
+        wait = 30
+        log.info("\nWait %d seconds..." % wait)
+        sum = 0
+#        cdata = zstd.compress(tDATA)
+#        cdata = b'\x28\xb5\x2f\xfd\x00\x58\x11\x00\x00\x7b\x7d'
+        f = open("tests/test_data/facebook.ico.zst","rb")
+        cdata = f.read()
+        f.close()
+        l=len(cdata)
+        tbegin = time()
+        while time()-tbegin<wait:
+            data = zstd.decompress(cdata)
+            sum+=l
+
+        log.info("Decompression of streamed datspeed average = %6f Mb/sec" % (1.0*sum/1024/1024/wait,))
 
     def test_check_speed(self):
         wait = 30