call release() for each processor at the end of the pipe run

fix some tests

diff --git a/tests/api/test_enc_flac.py b/tests/api/test_enc_flac.py
new file mode 100644 (file)
index 0000000..17e604a
--- /dev/null
+++ b/tests/api/test_enc_flac.py
@@ -0,0 +1,14 @@
+# -*- coding: utf-8 -*-
+
+from timeside.decoder import *
+from timeside.encoder import *
+import os.path
+import sys
+
+source = sys.argv[-1]
+dest = source+'.flac'
+
+decoder  = FileDecoder(source)
+encoder  = FlacEncoder(dest, overwrite=True)
+
+(decoder | encoder).run()

diff --git a/tests/api/test_enc_mp3.py b/tests/api/test_enc_mp3.py
index 24390271b3cadd784c84480402634294c2e28428..2dea63ccf6156d0becc20cb4dfbf28dc0c0ae13b 100644 (file)
--- a/tests/api/test_enc_mp3.py
+++ b/tests/api/test_enc_mp3.py
@@ -15,7 +15,7 @@ dest = source+'.mp3'
 print 'converting', source, 'to', dest
 
 decoder  = FileDecoder(source)
-encoder  = Mp3Encoder(dest)
+encoder  = Mp3Encoder(dest, overwrite=True)
 
 (decoder | encoder).run()
 

diff --git a/tests/api/test_enc_ogg.py b/tests/api/test_enc_ogg.py
index 5c2947e8066f9cb195d63aa1c1a09e5ef8a6b663..b6be59970c8581285ef7e26af718ecfcc6ad2d83 100644 (file)
--- a/tests/api/test_enc_ogg.py
+++ b/tests/api/test_enc_ogg.py
@@ -15,6 +15,6 @@ dest = source+'.ogg'
 print 'converting', source, 'to', dest
 
 decoder  = FileDecoder(source)
-encoder  = VorbisEncoder(dest)
+encoder  = VorbisEncoder(dest, overwrite=True)
 
 (decoder | encoder).run()

diff --git a/timeside/core.py b/timeside/core.py
index 909109fb7f572d316e8194b0eb6626b4623a3ef5..1f8337af7519bc6f08b5e28f3917c68193021c9d 100644 (file)
--- a/timeside/core.py
+++ b/timeside/core.py
@@ -229,4 +229,7 @@ class ProcessPipe(object):
             for item in items:
                 frames, eod = item.process(frames, eod)
 
+        for item in items:
+            item.release()
+
         return self