39 RS&& selector)
const {
40 return [func, sb, se, driver, initFunc, selector](
auto in) {
42 [in, func, sb, se, driver, initFunc, selector](
auto out)
mutable {
47 [func, sb, se, driver, initFunc, selector](
48 auto& out,
auto input) {
PUSHMI_INLINE_VAR constexpr detail::submit_fn submit
auto operator()(F &&func, ShapeBegin sb, ShapeEnd se, Target &&driver, IF &&initFunc, RS &&selector) const
constexpr detail::Map< Move > move
—— Concurrent Priority Queue Implementation ——
#define PUSHMI_INLINE_VAR
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::operators::bulk_fn bulk
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::make_receiver_fn make_receiver
PUSHMI_INLINE_VAR constexpr struct folly::pushmi::make_single_sender_fn make_single_sender