54 e_(getExecutorFrom(future)),
55 priority_(future.getPriority()) {
66 throw_exception<FutureSplitterInvalid>();
68 return promise_->getSemiFuture().via(e_, priority_);
76 throw_exception<FutureSplitterInvalid>();
SemiFuture< T > getSemiFuture()
Executor * getExecutor() const
FutureSplitter< T > splitFuture(Future< T > &&future)
constexpr detail::Map< Move > move
—— Concurrent Priority Queue Implementation ——
std::shared_ptr< SharedPromise< T > > promise_
static Executor * getExecutorFrom(Future< T > &f)
FOLLY_ATTR_VISIBILITY_HIDDEN static FOLLY_ALWAYS_INLINE InlineExecutor & instance() noexcept
FutureSplitter(Future< T > &&future)