QuantumLibrary
|
#include <quantum_shared_state.h>
Public Member Functions | |
template<class V = T> | |
void | push (V &&value) |
template<class V = T> | |
void | push (ICoroSync::Ptr sync, V &&value) |
T | pull (bool &isBufferClosed) |
T | pull (ICoroSync::Ptr sync, bool &isBufferClosed) |
void | breakPromise () |
void | wait () const |
void | wait (ICoroSync::Ptr sync) const |
template<class REP , class PERIOD > | |
std::future_status | waitFor (const std::chrono::duration< REP, PERIOD > &time) const |
template<class REP , class PERIOD > | |
std::future_status | waitFor (ICoroSync::Ptr sync, const std::chrono::duration< REP, PERIOD > &time) const |
int | setException (std::exception_ptr ex) |
int | setException (ICoroSync::Ptr sync, std::exception_ptr ex) |
int | closeBuffer () |
Friends | |
class | Promise< Buffer< T > > |
void Bloomberg::quantum::SharedState< Buffer< T > >::breakPromise | ( | ) |
int Bloomberg::quantum::SharedState< Buffer< T > >::closeBuffer | ( | ) |
T Bloomberg::quantum::SharedState< Buffer< T > >::pull | ( | bool & | isBufferClosed | ) |
T Bloomberg::quantum::SharedState< Buffer< T > >::pull | ( | ICoroSync::Ptr | sync, |
bool & | isBufferClosed | ||
) |
void Bloomberg::quantum::SharedState< Buffer< T > >::push | ( | V && | value | ) |
void Bloomberg::quantum::SharedState< Buffer< T > >::push | ( | ICoroSync::Ptr | sync, |
V && | value | ||
) |
int Bloomberg::quantum::SharedState< Buffer< T > >::setException | ( | std::exception_ptr | ex | ) |
int Bloomberg::quantum::SharedState< Buffer< T > >::setException | ( | ICoroSync::Ptr | sync, |
std::exception_ptr | ex | ||
) |
void Bloomberg::quantum::SharedState< Buffer< T > >::wait | ( | ) | const |
void Bloomberg::quantum::SharedState< Buffer< T > >::wait | ( | ICoroSync::Ptr | sync | ) | const |
std::future_status Bloomberg::quantum::SharedState< Buffer< T > >::waitFor | ( | const std::chrono::duration< REP, PERIOD > & | time | ) | const |
std::future_status Bloomberg::quantum::SharedState< Buffer< T > >::waitFor | ( | ICoroSync::Ptr | sync, |
const std::chrono::duration< REP, PERIOD > & | time | ||
) | const |