diff --git a/src/input/ThreadInputStream.cxx b/src/input/ThreadInputStream.cxx index 36f77d557..231cb5cd9 100644 --- a/src/input/ThreadInputStream.cxx +++ b/src/input/ThreadInputStream.cxx @@ -26,6 +26,17 @@ #include #include +ThreadInputStream::ThreadInputStream(const char *_plugin, + const char *_uri, + Mutex &_mutex, Cond &_cond, + size_t _buffer_size) + :InputStream(_uri, _mutex, _cond), + plugin(_plugin), + thread(BIND_THIS_METHOD(ThreadFunc)), + buffer_size(_buffer_size) +{ +} + ThreadInputStream::~ThreadInputStream() { { diff --git a/src/input/ThreadInputStream.hxx b/src/input/ThreadInputStream.hxx index 046e0821c..70e8777ba 100644 --- a/src/input/ThreadInputStream.hxx +++ b/src/input/ThreadInputStream.hxx @@ -70,11 +70,7 @@ class ThreadInputStream : public InputStream { public: ThreadInputStream(const char *_plugin, const char *_uri, Mutex &_mutex, Cond &_cond, - size_t _buffer_size) - :InputStream(_uri, _mutex, _cond), - plugin(_plugin), - thread(BIND_THIS_METHOD(ThreadFunc)), - buffer_size(_buffer_size) {} + size_t _buffer_size); virtual ~ThreadInputStream();