Merge pull request #6 from BlackMATov/dev

Dev

README.md

@@ -28,4 +28,160 @@
 #include "promise.hpp"
 ```
 
+## Examples
+
+### Creating a promise
+
+```cpp
+#include "promise.hpp"
+using promise_hpp;
+
+promise<std::string> download(const std::string& url)
+{
+    promise<std::string> result;
+
+    web_client.download_with_callbacks(
+        [result](const std::string& html)
+        {
+            result.resolve(html);
+        },
+        [result](int error_code)
+        {
+            result.reject(std::runtime_error("error code: " + std::string(error_code)));
+        });
+
+    return result;
+}
+```
+
+### Alternative way to create a promise
+
+```cpp
+promise<std::string> p = make_promise<std::string>(
+    [](auto&& resolver, auto&& rejector)
+    {
+        web_client.download_with_callbacks(
+            [resolver](const std::string& html)
+            {
+                resolver(html);
+            },
+            [rejector](int error_code)
+            {
+                rejector(std::runtime_error("error code: " + std::string(error_code)));
+            });
+    });
+```
+
+### Waiting for an async operation
+
+```cpp
+download("http://www.google.com")
+    .then([](const std::string& html)
+    {
+        std::cout << html << std::endl;
+    })
+    .except([](std::exception_ptr e)
+    {
+        try {
+            std::rethrow_exception(e);
+        } catch (const std::exception& ee) {
+            std::cerr << ee.what() << std::endl;
+        }
+    });
+```
+
+### Chaining async operations
+
+```cpp
+download("http://www.google.com")
+    .then([](const std::string& html)
+    {
+        return download(extract_first_link(html));
+    })
+    .then([](const std::string& first_link_html)
+    {
+        std::cout << first_link_html << std::endl;
+    })
+    .except([](std::exception_ptr e)
+    {
+        try {
+            std::rethrow_exception(e);
+        } catch (const std::exception& ee) {
+            std::cerr << ee.what() << std::endl;
+        }
+    });
+```
+
+### Transforming promise results
+
+```cpp
+download("http://www.google.com")
+    .then([](const std::string& html)
+    {
+        return extract_all_links(html);
+    })
+    .then([](const std::vector<std::string>& links)
+    {
+        for ( const std::string& link : links ) {
+            std::cout << link << std::endl;
+        }
+    });
+```
+
+### Combining multiple async operations
+
+```cpp
+std::vector<std::string> urls{
+    "http://www.google.com",
+    "http://www.yandex.ru"};
+
+std::vector<promise<std::string>> url_promises;
+std::transform(urls.begin(), urls.end(), url_promises.begin(), download);
+
+pr::make_all_promise(url_promises)
+    .then([](const std::vector<std::string>& pages)
+    {
+        std::vector<std::string> all_links;
+        for ( const std::string& page : pages ) {
+            std::vector<std::string> page_links = extract_all_links(page);
+            all_links.insert(
+                all_links.end(),
+                std::make_move_iterator(page_links.begin()),
+                std::make_move_iterator(page_links.end()));
+        }
+        return all_links;
+    })
+    .then([](const std::vector<std::string>& all_links)
+    {
+        for ( const std::string& link : all_links ) {
+            std::cout << link << std::endl;
+        }
+    });
+```
+
+### Chaining multiple async operations
+
+```cpp
+download("http://www.google.com")
+    .then_all([](const std::string& html)
+    {
+        std::vector<pr::promise<std::string>> url_promises;
+        std::vector<std::string> links = extract_all_links(html);
+        std::transform(links.begin(), links.end(), url_promises.begin(), download);
+        return url_promises;
+    })
+    .then([](const std::vector<std::string>& all_link_page_htmls)
+    {
+        // ...
+    })
+    .except([](std::exception_ptr e)
+    {
+        // ...
+    });
+```
+
+## API
+
+> coming soon!
+
 ## [License (MIT)](./LICENSE.md)

promise.hpp

@@ -1,3 +1,9 @@
+/*******************************************************************************
+ * This file is part of the "promise.hpp"
+ * For conditions of distribution and use, see copyright notice in LICENSE.md
+ * Copyright (C) 2018 Matvey Cherevko
+ ******************************************************************************/
+
 #pragma once
 
 #include <cstdint>
@@ -418,9 +424,9 @@ namespace promise_hpp
                 auto np = invoke_hpp::invoke(
                     std::forward<decltype(f)>(f),
                     v);
-                np.then([n = n]() mutable {
+                np.then([n]() mutable {
                     n.resolve();
-                }, [n = n](std::exception_ptr e) mutable {
+                }, [n](std::exception_ptr e) mutable {
                     n.reject(e);
                 });
             }, [n = next](std::exception_ptr e) mutable {
@@ -445,9 +451,9 @@ namespace promise_hpp
                 auto np = invoke_hpp::invoke(
                     std::forward<decltype(f)>(f),
                     v);
-                np.then([n = n](const typename ResolveFR::value_type& nv) mutable {
+                np.then([n](const typename ResolveFR::value_type& nv) mutable {
                     n.resolve(nv);
-                }, [n = n](std::exception_ptr e) mutable {
+                }, [n](std::exception_ptr e) mutable {
                     n.reject(e);
                 });
             }, [n = next](std::exception_ptr e) mutable {
@@ -746,9 +752,9 @@ namespace promise_hpp
             ]() mutable {
                 auto np = invoke_hpp::invoke(
                     std::forward<decltype(f)>(f));
-                np.then([n = n]() mutable {
+                np.then([n]() mutable {
                     n.resolve();
-                }, [n = n](std::exception_ptr e) mutable {
+                }, [n](std::exception_ptr e) mutable {
                     n.reject(e);
                 });
             }, [n = next](std::exception_ptr e) mutable {
@@ -772,9 +778,9 @@ namespace promise_hpp
             ]() mutable {
                 auto np = invoke_hpp::invoke(
                     std::forward<decltype(f)>(f));
-                np.then([n = n](const typename ResolveFR::value_type& nv) mutable {
+                np.then([n](const typename ResolveFR::value_type& nv) mutable {
                     n.resolve(nv);
-                }, [n = n](std::exception_ptr e) mutable {
+                }, [n](std::exception_ptr e) mutable {
                     n.reject(e);
                 });
             }, [n = next](std::exception_ptr e) mutable {

tests.cpp

@@ -1,3 +1,9 @@
+/*******************************************************************************
+ * This file is part of the "promise.hpp"
+ * For conditions of distribution and use, see copyright notice in LICENSE.md
+ * Copyright (C) 2018 Matvey Cherevko
+ ******************************************************************************/
+
 #define CATCH_CONFIG_MAIN
 #include "catch.hpp"