QuantumLibrary
Bloomberg::quantum::ICoroContext< RET > Member List

This is the complete list of members for Bloomberg::quantum::ICoroContext< RET >, including all inherited members.

closeBuffer()Bloomberg::quantum::ICoroContext< RET >
ContextTag typedefBloomberg::quantum::ICoroContext< RET >
end()Bloomberg::quantum::ICoroContext< RET >
finally(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
finally(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
forEach(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::ICoroContext< RET >
forEach(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::ICoroContext< RET >
forEach(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::ICoroContext< RET >
forEach(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::ICoroContext< RET >
forEachBatch(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::ICoroContext< RET >
forEachBatch(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::ICoroContext< RET >
forEachBatch(INPUT_IT first, INPUT_IT last, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::ICoroContext< RET >
forEachBatch(INPUT_IT first, size_t num, Functions::ForEachFunc< OTHER_RET, INPUT_IT > func)Bloomberg::quantum::ICoroContext< RET >
get(ICoroSync::Ptr sync)Bloomberg::quantum::ICoroContext< RET >
getAt(int num, ICoroSync::Ptr sync)Bloomberg::quantum::ICoroContext< RET >
getCoroQueueIdRangeForAny() constBloomberg::quantum::ICoroContext< RET >
getNumCoroutineThreads() constBloomberg::quantum::ICoroContext< RET >
getNumIoThreads() constBloomberg::quantum::ICoroContext< RET >
getPrev()Bloomberg::quantum::ICoroContext< RET >
getPrevRef()Bloomberg::quantum::ICoroContext< RET >
getRef(ICoroSync::Ptr sync) constBloomberg::quantum::ICoroContext< RET >
getRefAt(int num, ICoroSync::Ptr sync) constBloomberg::quantum::ICoroContext< RET >
getYieldHandle()=0Bloomberg::quantum::ICoroSyncpure virtual
Impl typedefBloomberg::quantum::ICoroContext< RET >
mapReduce(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::ICoroContext< RET >
mapReduce(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::ICoroContext< RET >
mapReduce(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::ICoroContext< RET >
mapReduce(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::ICoroContext< RET >
mapReduceBatch(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::ICoroContext< RET >
mapReduceBatch(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::ICoroContext< RET >
mapReduceBatch(INPUT_IT first, INPUT_IT last, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::ICoroContext< RET >
mapReduceBatch(INPUT_IT first, size_t num, Functions::MapFunc< KEY, MAPPED_TYPE, INPUT_IT > mapper, Functions::ReduceFunc< KEY, MAPPED_TYPE, REDUCED_TYPE > reducer)Bloomberg::quantum::ICoroContext< RET >
onError(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
onError(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
post(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
post(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
post(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
post(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
postAsyncIo(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
postAsyncIo(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
postFirst(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
postFirst(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
postFirst(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
postFirst(int queueId, bool isHighPriority, FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
Ptr typedefBloomberg::quantum::ICoroContext< RET >
pull(ICoroSync::Ptr sync, bool &isBufferClosed)Bloomberg::quantum::ICoroContext< RET >
push(V &&value)Bloomberg::quantum::ICoroContext< RET >
set(V &&value)Bloomberg::quantum::ICoroContext< RET >
setException(std::exception_ptr ex)=0Bloomberg::quantum::IContextBasepure virtual
setYieldHandle(Traits::Yield &yield)=0Bloomberg::quantum::ICoroSyncpure virtual
signal()=0Bloomberg::quantum::ICoroSyncpure virtual
sleep(const std::chrono::milliseconds &timeMs)=0Bloomberg::quantum::ICoroSyncpure virtual
sleep(const std::chrono::microseconds &timeUs)=0Bloomberg::quantum::ICoroSyncpure virtual
then(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
then(FUNC &&func, ARGS &&... args)Bloomberg::quantum::ICoroContext< RET >
valid() const =0Bloomberg::quantum::IContextBasepure virtual
validAt(int num) const =0Bloomberg::quantum::IContextBasepure virtual
wait(ICoroSync::Ptr sync) const =0Bloomberg::quantum::ICoroContextBasepure virtual
waitAll(ICoroSync::Ptr sync) const =0Bloomberg::quantum::ICoroContextBasepure virtual
waitAt(int num, ICoroSync::Ptr sync) const =0Bloomberg::quantum::ICoroContextBasepure virtual
waitFor(ICoroSync::Ptr sync, std::chrono::milliseconds timeMs) const =0Bloomberg::quantum::ICoroContextBasepure virtual
waitForAt(int num, ICoroSync::Ptr sync, std::chrono::milliseconds timeMs) const =0Bloomberg::quantum::ICoroContextBasepure virtual
yield()=0Bloomberg::quantum::ICoroSyncpure virtual
~IContextBase()=defaultBloomberg::quantum::IContextBasevirtual
~ICoroSync()=defaultBloomberg::quantum::ICoroSyncvirtual