2 files changed, 8 insertions, 3 deletions
diff --git a/decoders/mpg123_decoder.cpp b/decoders/mpg123_decoder.cpp
index 0c2629f..a195c58 100644
--- a/decoders/mpg123_decoder.cpp
+++ b/decoders/mpg123_decoder.cpp
@@ -26,8 +26,13 @@ DecoderMpg123::~DecoderMpg123() {
 	mpg123_delete(handle);
 }
 
-size_t DecoderMpg123::decode(const uint8_t *input, size_t input_size, uint8_t *output, size_t output_size) {
-	if(mpg123_feed(handle, input, input_size) != MPG123_OK) {
+size_t DecoderMpg123::decode(Source& input, uint8_t *output, size_t output_size) {
+	char src_data[0x2000];
+	std::streamsize src_read = input.read(src_data, 0x2000);
+	if(src_read < 0)
+		src_read = 0;
+	
+	if(mpg123_feed(handle, (uint8_t*)src_data, src_read) != MPG123_OK) {
 		throw std::runtime_error(mpg123_strerror(handle));
 	}
 
diff --git a/decoders/mpg123_decoder.h b/decoders/mpg123_decoder.h
index 46f9e4c..9e2bcdf 100644
--- a/decoders/mpg123_decoder.h
+++ b/decoders/mpg123_decoder.h
@@ -12,7 +12,7 @@ class DecoderMpg123 : public DecoderBase {
 	public:
 		DecoderMpg123();
 		~DecoderMpg123();
-		size_t decode(const uint8_t *input, size_t input_size, uint8_t *output, size_t output_size);
+		size_t decode(Source& input, uint8_t *output, size_t output_size);
 };
 
 #endif