continuable/test.cpp
2015-06-10 19:02:35 +02:00

206 lines
4.4 KiB
C++

#include "fluent++.hpp"
#include "Callback.h"
#include "WeakCallbackContainer.h"
#include "Continuable.h"
#include <iostream>
#include <exception>
enum SpellCastResult
{
SPELL_FAILED_SUCCESS = 0,
SPELL_FAILED_AFFECTING_COMBAT = 1,
SPELL_FAILED_ALREADY_AT_FULL_HEALTH = 2,
SPELL_FAILED_ALREADY_AT_FULL_MANA = 3,
SPELL_FAILED_ALREADY_AT_FULL_POWER = 4,
SPELL_FAILED_ALREADY_BEING_TAMED = 5
};
/*
ProtoContinueable ProtoCastSpell(int id)
{
std::cout << "Cast " << id << std::endl;
// on success call true
return ProtoContinueable();
}
ProtoContinueable ProtoMoveTo(int point)
{
std::cout << "Move to point " << point << std::endl;
// on success call true
return ProtoContinueable();
}
void ProtoCastSpell(int id, Callback<SpellCastResult> const& callback)
{
std::cout << "Cast " << id << std::endl;
// on success call the callback with SPELL_FAILED_SUCCESS
callback(SPELL_FAILED_SUCCESS);
void ProtoMoveTo(int point, Callback<bool> const& callback)
{
std::cout << "Move to point " << point << std::endl;
// on success call true
callback(true);
}
}
*/
Continuable<Callback<SpellCastResult>> CastSpell(int id)
{
return make_continuable([=](Callback<SpellCastResult>&& callback)
{
std::cout << "Cast " << id << std::endl;
// on success call the callback with SPELL_FAILED_SUCCESS
callback(SPELL_FAILED_SUCCESS);
});
}
int main(int argc, char** argv)
{
/*
make_waterfall<Callback<SpellCastResult>>()
// .then(std::bind(&CastSpell, 71382, std::placeholders::_1))
.then([](SpellCastResult result, Callback<bool> const& callback)
{
ProtoMoveTo(1, callback);
})
.then([](bool success)
{
// Do something final
std::cout << "finish everything" << std::endl;
});
auto cabt = []()
{
// Do something
return ProtoMoveTo(2);
};
typedef Callback<bool> cbd1;
typedef WeakCallback<int> cbd2;
typedef SharedCallback<std::string> cbd3;
cbd1 _cbd1;
cbd2 _cbd2;
cbd3 _cbd3;
auto _test_make_shared_callback = make_shared_callback([](bool)
{
});
Callback<> weak_cb_test;
{
WeakCallbackContainer callback;
// Some tests
ProtoCastSpell(22872)
.weak(callback)
.then([](bool success)
{
if (success)
{
// do something
}
// Do something
return ProtoMoveTo(2);
})
.then([]
{
});
std::shared_ptr<int> dealloc_test(new int{2}, [](int* me)
{
std::cout << "dealloc ok" << std::endl;
delete me;
});
auto const cb_void = callback([dealloc_test]
{
std::cout << "huhu i'm a..." << std::endl;
auto const cp = dealloc_test;
});
dealloc_test.reset();
auto const cb_bool = callback([](bool success)
{
std::cout << "...weak wrapped callback!" << std::endl;
});
weak_cb_test = callback([]
{
std::cout << "huhu i'm crashsafe (you wont see me)!" << std::endl;
std::logic_error("bad logic");
});
cb_void();
int i = 0;
++i;
cb_bool(true);
}
// This will never be executed because the CallbackContainer was deallocated and its weak callback proxies are crash safe.
weak_cb_test();
auto weak_2 = make_shared_callback([]
{
std::cout << "huhu" << std::endl;
});
auto wrapped = make_weak_wrapped_callback(weak_2);
auto wrapped2 = make_weak_wrapped_callback(WeakCallback<>(weak_2));
wrapped();
wrapped2();
*/
typedef Continuable<Callback<bool>> cont123;
// typedef Continuable<Callback<bool>>::type myty1;
// typedef Continuable<Callback<bool>, float>::type myty2;
// Continuable<Callback<SpellCastResult>>
CastSpell(63362)
.then([](SpellCastResult result)
{
return CastSpell(63362);
})
.then([](SpellCastResult result)
{
});
// Wraps a callback function into a continuable
auto cba1 = make_continuable([=](Callback<SpellCastResult>&& callback)
{
});
return 0;
}