#ifndef SRC_UV_ASYNC_QUEUE_H
#define SRC_UV_ASYNC_QUEUE_H

template <class T>
class UVQueue{
	public:
		typedef void (*fptr)(T);

		Napi::ThreadSafeFunction tsfn;

		UVQueue(fptr cb): callback(cb)  {}

		void start(Napi::Env env) {
			Napi::Function empty_func = Napi::Function::New(env, [](const Napi::CallbackInfo& cb) {});
			tsfn = Napi::ThreadSafeFunction::New(env, empty_func, "libusb", 0, 1);
		}

		void stop() {
    		tsfn.Release();
		}
		
		void post(T value){
			auto cb = callback;
			tsfn.BlockingCall( value, [cb](Napi::Env _env, Napi::Function _jsCallback, T val) {
				cb(val);
			});
		}

	private:
		fptr callback;
};

#endif