Add a reset() method to batch.

src/backends/redis/batch.cpp

@@ -133,6 +133,7 @@ namespace redis {
 	}
 
 	Batch::~Batch() noexcept {
+		this->reset();
 	}
 
 	void Batch::run_pvt (int parArgc, const char** parArgv, std::size_t* parLengths) {
@@ -192,6 +193,19 @@ namespace redis {
 		}
 	}
 
+	void Batch::reset() noexcept {
+		try {
+			this->replies(); //force waiting for any pending jobs
+		}
+		catch (...) {
+			assert(false);
+		}
+
+		assert(0 == m_local_data->pending_futures);
+		m_futures.clear();
+		m_replies.clear();
+	}
+
 	RedisError::RedisError (const char* parMessage, std::size_t parLength) :
 		std::runtime_error(std::string(parMessage, parLength))
 	{

src/backends/redis/batch.hpp

@@ -49,6 +49,8 @@ namespace redis {
 		template <typename... Args>
 		Batch& operator() ( const char* parCommand, Args&&... parArgs );
 
+		void reset ( void ) noexcept;
+
 	private:
 		struct LocalData;