: public Decoder,

public std::enable_shared_from_this<DecoderNormalisationImplementation> {

public:

typedef enum : int { ErrorCodeCouldNotDecodeHeader } ErrorCode;

DecoderNormalisationImplementation(const std::shared_ptr<Decoder> &wrapped_decoder,

const double samplerate,

const int channels);

virtual ~DecoderNormalisationImplementation();

// Decoder

virtual double sampleRate();

virtual int channels();

virtual long currentFrameIndex();

virtual void seek(long frame_index);

virtual long frames();

virtual void decode(long frames, const DECODE_CALLBACK &decode_callback, bool synchronous);

virtual bool eof();

virtual const std::string &path();

virtual const std::string &name();

virtual void flush();

virtual void load(const ERROR_DECODER_CALLBACK &decoder_error_callback,

const LOAD_DECODER_CALLBACK &decoder_load_callback);

private:

const std::shared_ptr<Decoder> _wrapped_decoder;

double _factor;

void *_resampler_handlers[2];

std::atomic<long> _frame_index;

std::mutex _resampler_mutex;

std::vector<float> _pcm_buffer;

std::atomic<double> _samplerate;

std::atomic_int _channels;