Lines Matching refs:buffered_channel

193 void wait_first_value_impl( std::shared_ptr< boost::fibers::buffered_channel< T > > chan,  in wait_first_value_impl()
205 void wait_first_value_impl( std::shared_ptr< boost::fibers::buffered_channel< T > > chan,  in wait_first_value_impl()
226     typedef boost::fibers::buffered_channel< return_t > channel_t;  in wait_first_value()
311     typedef boost::fibers::buffered_channel< future_t > channel_t;  in wait_first_outcome()
404     typedef boost::fibers::buffered_channel< future_t > channel_t;  in wait_first_success()
479     typedef boost::fibers::buffered_channel< return_t > channel_t;  in wait_first_value_het()
568     nchannel( std::shared_ptr< boost::fibers::buffered_channel< T > > chan,  in nchannel()
590     std::shared_ptr< boost::fibers::buffered_channel< T > >    chan_;
624 std::shared_ptr< boost::fibers::buffered_channel< typename std::result_of< Fn() >::type > >
628     typedef boost::fibers::buffered_channel< return_t > channel_t;  in wait_all_values_source()
656     std::shared_ptr< boost::fibers::buffered_channel< return_t > > chan =  in wait_all_values()
671     std::shared_ptr< boost::fibers::buffered_channel< std::string > > chan =  in __anond3e8e7a32502()
705     boost::fibers::buffered_channel<
712     typedef boost::fibers::buffered_channel< future_t > channel_t;  in wait_all_until_error_source()
743         boost::fibers::buffered_channel< future_t > > chan(  in wait_all_until_error()
759     std::shared_ptr< boost::fibers::buffered_channel< future_t > > chan =  in __anond3e8e7a32c02()
834         boost::fibers::buffered_channel< future_t > > chan(  in wait_all_collect_errors()