54 lines
1.2 KiB
C++
54 lines
1.2 KiB
C++
|
|
// 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 <boost/coroutine/all.hpp>
|
|
|
|
#include <cstdlib>
|
|
#include <iostream>
|
|
#include <stdexcept>
|
|
#include <string>
|
|
|
|
#include <boost/bind.hpp>
|
|
#include <boost/throw_exception.hpp>
|
|
|
|
typedef boost::coroutines::asymmetric_coroutine< int >::pull_type pull_coro_t;
|
|
typedef boost::coroutines::asymmetric_coroutine< int >::push_type push_coro_t;
|
|
|
|
struct my_exception : public std::runtime_error
|
|
{
|
|
my_exception( std::string const& str) :
|
|
std::runtime_error( str)
|
|
{}
|
|
};
|
|
|
|
void echo( push_coro_t & sink, int j)
|
|
{
|
|
for ( int i = 0; i < j; ++i)
|
|
{
|
|
if ( i == 5) boost::throw_exception( my_exception("abc") );
|
|
sink( i);
|
|
}
|
|
}
|
|
|
|
int main( int argc, char * argv[])
|
|
{
|
|
pull_coro_t source( boost::bind( echo, _1, 10) );
|
|
try
|
|
{
|
|
while ( source)
|
|
{
|
|
std::cout << source.get() << std::endl;
|
|
source();
|
|
}
|
|
}
|
|
catch ( my_exception const& ex)
|
|
{ std::cout << "exception: " << ex.what() << std::endl; }
|
|
|
|
std::cout << "\nDone" << std::endl;
|
|
|
|
return EXIT_SUCCESS;
|
|
}
|