cannam@140: #ifndef INCLUDED_PORTAUDIO_MEMFUNCALLBACKSTREAM_HXX
cannam@140: #define INCLUDED_PORTAUDIO_MEMFUNCALLBACKSTREAM_HXX
cannam@140: 
cannam@140: // ---------------------------------------------------------------------------------------
cannam@140: 
cannam@140: #include "portaudio.h"
cannam@140: 
cannam@140: #include "portaudiocpp/CallbackStream.hxx"
cannam@140: #include "portaudiocpp/CallbackInterface.hxx"
cannam@140: #include "portaudiocpp/StreamParameters.hxx"
cannam@140: #include "portaudiocpp/Exception.hxx"
cannam@140: #include "portaudiocpp/InterfaceCallbackStream.hxx"
cannam@140: 
cannam@140: // ---------------------------------------------------------------------------------------
cannam@140: 
cannam@140: namespace portaudio
cannam@140: {
cannam@140: 
cannam@140: 
cannam@140: 	//////
cannam@140: 	/// @brief Callback stream using a class's member function as a callback. Template argument T is the type of the 
cannam@140: 	/// class of which a member function is going to be used.
cannam@140: 	///
cannam@140: 	/// Example usage:
cannam@140: 	/// @verbatim MemFunCallback<MyClass> stream = MemFunCallbackStream(parameters, *this, &MyClass::myCallbackFunction); @endverbatim
cannam@140: 	//////
cannam@140: 	template<typename T>
cannam@140: 	class MemFunCallbackStream : public CallbackStream
cannam@140: 	{
cannam@140: 	public:
cannam@140: 		typedef int (T::*CallbackFunPtr)(const void *, void *, unsigned long, const PaStreamCallbackTimeInfo *, 
cannam@140: 			PaStreamCallbackFlags);
cannam@140: 
cannam@140: 		// -------------------------------------------------------------------------------
cannam@140: 
cannam@140: 		MemFunCallbackStream()
cannam@140: 		{
cannam@140: 		}
cannam@140: 
cannam@140: 		MemFunCallbackStream(const StreamParameters &parameters, T &instance, CallbackFunPtr memFun) : adapter_(instance, memFun)
cannam@140: 		{
cannam@140: 			open(parameters);
cannam@140: 		}
cannam@140: 
cannam@140: 		~MemFunCallbackStream()
cannam@140: 		{
cannam@140: 			close();
cannam@140: 		}
cannam@140: 
cannam@140: 		void open(const StreamParameters &parameters, T &instance, CallbackFunPtr memFun)
cannam@140: 		{
cannam@140: 			// XXX:	need to check if already open?
cannam@140: 
cannam@140: 			adapter_.init(instance, memFun);
cannam@140: 			open(parameters);
cannam@140: 		}
cannam@140: 
cannam@140: 	private:
cannam@140: 		MemFunCallbackStream(const MemFunCallbackStream &); // non-copyable
cannam@140: 		MemFunCallbackStream &operator=(const MemFunCallbackStream &); // non-copyable
cannam@140: 
cannam@140: 		//////
cannam@140: 		/// @brief Inner class which adapts a member function callback to a CallbackInterface compliant 
cannam@140: 		/// class (so it can be adapted using the paCallbackAdapter function).
cannam@140: 		//////
cannam@140: 		class MemFunToCallbackInterfaceAdapter : public CallbackInterface
cannam@140: 		{
cannam@140: 		public:
cannam@140: 			MemFunToCallbackInterfaceAdapter() {}
cannam@140: 			MemFunToCallbackInterfaceAdapter(T &instance, CallbackFunPtr memFun) : instance_(&instance), memFun_(memFun) {}
cannam@140: 
cannam@140: 			void init(T &instance, CallbackFunPtr memFun)
cannam@140: 			{
cannam@140: 				instance_ = &instance;
cannam@140: 				memFun_ = memFun;
cannam@140: 			}
cannam@140: 
cannam@140: 			int paCallbackFun(const void *inputBuffer, void *outputBuffer, unsigned long numFrames, 
cannam@140: 				const PaStreamCallbackTimeInfo *timeInfo, PaStreamCallbackFlags statusFlags)
cannam@140: 			{
cannam@140: 				return (instance_->*memFun_)(inputBuffer, outputBuffer, numFrames, timeInfo, statusFlags);
cannam@140: 			}
cannam@140: 
cannam@140: 		private:
cannam@140: 			T *instance_;
cannam@140: 			CallbackFunPtr memFun_;
cannam@140: 		};
cannam@140: 
cannam@140: 		MemFunToCallbackInterfaceAdapter adapter_;
cannam@140: 
cannam@140: 		void open(const StreamParameters &parameters)
cannam@140: 		{
cannam@140: 			PaError err = Pa_OpenStream(&stream_, parameters.inputParameters().paStreamParameters(), parameters.outputParameters().paStreamParameters(), 
cannam@140: 				parameters.sampleRate(), parameters.framesPerBuffer(), parameters.flags(), &impl::callbackInterfaceToPaCallbackAdapter, 
cannam@140: 				static_cast<void *>(&adapter_));
cannam@140: 
cannam@140: 			if (err != paNoError)
cannam@140: 				throw PaException(err);
cannam@140: 		}
cannam@140: 	};
cannam@140: 
cannam@140: 
cannam@140: } // portaudio
cannam@140: 
cannam@140: // ---------------------------------------------------------------------------------------
cannam@140: 
cannam@140: #endif // INCLUDED_PORTAUDIO_MEMFUNCALLBACKSTREAM_HXX