Stop encoding if case of pipe input and no writer

2 files changed, 16 insertions, 26 deletions

diff --git a/src/main.cpp b/src/main.cpp
index bd961ec..f4d0f6b 100644
--- a/src/main.cpp
+++ b/src/main.cpp
@@ -385,17 +385,17 @@ int main_(int argc, char* const* argv)
     }
     catch (TAeaIOError err) {
         cerr << "Aea IO fatal error: " << err.what() << endl;
-		return 1;
+        return 1;
     }
-    catch (TWavIOError err) {
-        cerr << "Wav IO fatal error: " << err.what() << endl;
-		return 1;
+    catch (TNoDataToRead err) {
+        cerr << "No more data to read from input" << endl;
+        return 0;
     }
-	catch (const std::exception& ex) {
-		cerr << "Encode/Decode error: " << ex.what() << endl;
-		return 1;
-	}
-	return 0;
+    catch (const std::exception& ex) {
+        cerr << "Encode/Decode error: " << ex.what() << endl;
+        return 1;
+    }
+    return 0;
 }
 
 int main(int argc, char* const* argv) {
diff --git a/src/wav.h b/src/wav.h
index 06c6bfe..e3daf7d 100644
--- a/src/wav.h
+++ b/src/wav.h
@@ -26,22 +26,9 @@
 #include "pcmengin.h"
 
 class TFileAlreadyExists : public std::exception {
-
 };
 
-class TWavIOError : public std::exception {
-    const int ErrNum = 0;
-    const char* Text;
-public:
-    TWavIOError(const char* str, int err)
-        : ErrNum(err)
-        , Text(str)
-    {
-        (void)ErrNum;
-    }
-    virtual const char* what() const throw() {
-        return Text;
-    }
+class TNoDataToRead : public std::exception {
 };
 
 template<class T>
@@ -109,9 +96,12 @@ IPCMReader<T>* TWav::GetPCMReader() const {
     return new TWavPcmReader<T>([this](TPCMBuffer<T>& data, const uint32_t size) {
         if (data.Channels() != Impl->GetChannelsNum())
             throw TWrongReadBuffer(); 
-        if (size_t read = Impl->Read(data, size) != size) {
-            assert(read < size);
-            //fprintf(stderr, "to zero: %d\n", size-read);
+
+        size_t read;
+        if ((read = Impl->Read(data, size)) != size) {
+            if (!read)
+                throw TNoDataToRead();
+
             data.Zero(read, size - read);
         }
     });