coffee/continuable
1
0
Fork 0
mirror of https://github.com/Naios/continuable.git synced 2025-12-06 16:56:44 +08:00
Code Issues Packages Projects Releases Wiki Activity

some comments

Browse Source
This commit is contained in:
Naios 2015-07-06 14:46:15 +02:00
parent c5c875a5f5
commit f1d9dd94c8
1 changed files with 12 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
include/Continuable.h
View File

@ -542,7 +542,7 @@ namespace detail
template<typename Tuple, typename Current> template<typename Tuple, typename Current>
inline static void partial_set(Tuple& result, Current&& current) inline static void partial_set(Tuple& result, Current&& current)
{ {
// Store the callback result in the tuple // Store a single callback result in the tuple
std::get<Offset>(result) = std::forward<Current>(current); std::get<Offset>(result) = std::forward<Current>(current);
} }
@ -569,13 +569,17 @@ namespace detail
} }
template<typename... Args> template<typename... Args>
static void invoke( static void invoke(std::shared_ptr<multiple_result_storage_t<
std::shared_ptr<multiple_result_storage_t<fu::identity<_ATy...>, fu::identity<_RTy...>, fu::identity<_PTy...>>> storage, fu::identity<_ATy...>, fu::identity<_RTy...>, fu::identity<_PTy...>>> storage,
Continuable<Args...>&& continuable) Continuable<Args...>&& continuable)
{ {
// Invoke the continuable
continuable.invoke([storage](Args&&... args) continuable.invoke([storage](Args&&... args)
{ {
// Route its result to the cache.
store(storage->result, std::forward<Args>(args)...); store(storage->result, std::forward<Args>(args)...);
// Try to invoke the final callback.
storage->try_invoke(); storage->try_invoke();
}); });
} }
@ -624,8 +628,10 @@ namespace detail
template <typename _CTy, typename Arguments, typename... Rest> template <typename _CTy, typename Arguments, typename... Rest>
inline static void invoke(shared_result_t storage, Arguments&& args, _CTy&& current, Rest&&... rest) inline static void invoke(shared_result_t storage, Arguments&& args, _CTy&& current, Rest&&... rest)
{ {
// Invoke the current continuable...
invoke(storage, std::forward<Arguments>(args), std::forward<_CTy>(current)); invoke(storage, std::forward<Arguments>(args), std::forward<_CTy>(current));
// And continue with the next
distributor<Stack...>::invoke(storage, std::forward<Arguments>(args), std::forward<Rest>(rest)...); distributor<Stack...>::invoke(storage, std::forward<Arguments>(args), std::forward<Rest>(rest)...);
} }
}; };
@ -638,7 +644,8 @@ namespace detail
{ {
template <typename Arguments, typename TupleFunctional> template <typename Arguments, typename TupleFunctional>
inline static void invoke(shared_result_t result, Arguments&& arguments, TupleFunctional&& functional) inline static void invoke(shared_result_t result, Arguments&& arguments, TupleFunctional&& functional)
{ {
// Invoke the distributor which invokes all given continuables.
distributor<_PTy...>::invoke( distributor<_PTy...>::invoke(
result, result,
std::forward<Arguments>(arguments), std::forward<Arguments>(arguments),