asyymmetric-coroutine with placement new

example/cpp03/asymmetric/simple.cpp

@@ -1,26 +1,59 @@
-
-//          Copyright Oliver Kowalke 2009.
-// Distributed under the Boost Software License, Version 1.0.
-//    (See accompanying file LICENSE_1_0.txt or copy at
-//          http://www.boost.org/LICENSE_1_0.txt)
-
-#include <cstdio>
 #include <cstdlib>
 #include <iostream>
 
 #include <boost/bind.hpp>
 #include <boost/coroutine/all.hpp>
 
-void coro(boost::coroutines::coroutine<void>::pull_type& c)
+struct X
 {
-      std::printf("in coro!\n");
+    int i;
+
+    X( int i_) :
+        i( i_)
+    {}
+};
+
+typedef boost::coroutines::asymmetric_coroutine< X& >::pull_type pull_coro_t;
+typedef boost::coroutines::asymmetric_coroutine< X& >::push_type push_coro_t;
+
+void fn1( push_coro_t & sink)
+{
+    for ( int i = 0; i < 10; ++i)
+    {
+        X x( i);
+        sink( x);
+    }
 }
 
-int main()
+void fn2( pull_coro_t & source)
+{
+    while ( source) {
+        X & x = source.get();
+        std::cout << "i = " << x.i << std::endl;
+        source();
+    }
+}
+
+int main( int argc, char * argv[])
 {
     {
-      boost::coroutines::coroutine<void>::push_type p(coro);
-        std::printf("after construction\n");
+        pull_coro_t source( fn1);
+        while ( source) {
+            X & x = source.get();
+            std::cout << "i = " << x.i << std::endl;
+            source();
+        }
     }
+    {
+        push_coro_t sink( fn2);
+        for ( int i = 0; i < 10; ++i)
+        {
+            X x( i);
+            sink( x);
+        }
+    }
+    std::cout << "Done" << std::endl;
+
     return EXIT_SUCCESS;
 }
+