callback_thread.cpp

#include <mage.h>
#include <unistd.h>
#include <future>
#include <iostream>

using namespace mage;
using namespace std;

//
// All the code (well, almost)
// is the same as simple.cpp
//

int main() {
	mage::RPC client("game", "localhost:8080");

	//
	// However, we will store the result into
	// a future object
	//
	Json::Value params;

	//
	// I put things in my Json::Value.
	//
	params["password"] = "test";

	//
	// We make the call
	//
	// The third argument is meant to define the nature of
	// the future call:
	//
	//  - false: Run at call time (when you call res.get())
	//  - true: Run asynchronously
	//
	std::thread::id t1 = client.Call("user.register", params, [](mage::MageError err, Json::Value res) {
		std::cout << "1:Executed, we will now sleep for 1 second..." << std::endl;
		usleep(1000000);

		if (err.type() == MAGE_RPC_ERROR) {
			cerr << "An RPC error has occured: "  << err.what() << " (code " << err.code() << ")" << endl;
			return;
		}

		if (err.type() == MAGE_ERROR_MESSAGE) {
			cerr << "mymodule.mycommand responded with an error: "  << err.code() << endl;
			return;
		}

		cout << "user.register: " << res << endl;
	});

	std::thread::id t2 = client.Call("user.register", params, [](mage::MageError err, Json::Value res) {
		std::cout << "2:Executed, we will now sleep for 1 second..." << std::endl;
		usleep(1000000);

		if (err.type() == MAGE_RPC_ERROR) {
			cerr << "An RPC error has occured: "  << err.what() << " (code " << err.code() << ")" << endl;
			return;
		}

		if (err.type() == MAGE_ERROR_MESSAGE) {
			cerr << "mymodule.mycommand responded with an error: "  << err.code() << endl;
			return;
		}

		cout << "user.register: " << res << endl;
	});

	std::thread::id t3 = client.Call("user.register", params, [](mage::MageError err, Json::Value res) {
		std::cout << "3:Executed, we will now sleep for 1 second..." << std::endl;
		usleep(1000000);

		if (err.type() == MAGE_RPC_ERROR) {
			cerr << "An RPC error has occured: "  << err.what() << " (code " << err.code() << ")" << endl;
			return;
		}

		if (err.type() == MAGE_ERROR_MESSAGE) {
			cerr << "mymodule.mycommand responded with an error: "  << err.code() << endl;
			return;
		}

		cout << "user.register: " << res << endl;
	});

	cout << "Scheduled" << endl;

	client.Cancel(t1);
	cout << "t1 canceled" << endl;
	client.Join(t2);
	cout << "t2 joined" << endl;
	client.Join(t3);
	cout << "t3 joined" << endl;
}