QuantumLibrary
Bloomberg::quantum::SharedState< Buffer< T > > Class Template Reference

#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)
 
pull (bool &isBufferClosed)
 
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 > >
 

Member Function Documentation

◆ breakPromise()

template<class T >
void Bloomberg::quantum::SharedState< Buffer< T > >::breakPromise ( )

◆ closeBuffer()

template<class T >
int Bloomberg::quantum::SharedState< Buffer< T > >::closeBuffer ( )

◆ pull() [1/2]

template<class T >
T Bloomberg::quantum::SharedState< Buffer< T > >::pull ( bool &  isBufferClosed)

◆ pull() [2/2]

template<class T >
T Bloomberg::quantum::SharedState< Buffer< T > >::pull ( ICoroSync::Ptr  sync,
bool &  isBufferClosed 
)

◆ push() [1/2]

template<class T >
template<class V >
void Bloomberg::quantum::SharedState< Buffer< T > >::push ( V &&  value)

◆ push() [2/2]

template<class T >
template<class V >
void Bloomberg::quantum::SharedState< Buffer< T > >::push ( ICoroSync::Ptr  sync,
V &&  value 
)

◆ setException() [1/2]

template<class T >
int Bloomberg::quantum::SharedState< Buffer< T > >::setException ( std::exception_ptr  ex)

◆ setException() [2/2]

template<class T >
int Bloomberg::quantum::SharedState< Buffer< T > >::setException ( ICoroSync::Ptr  sync,
std::exception_ptr  ex 
)

◆ wait() [1/2]

template<class T >
void Bloomberg::quantum::SharedState< Buffer< T > >::wait ( ) const

◆ wait() [2/2]

template<class T >
void Bloomberg::quantum::SharedState< Buffer< T > >::wait ( ICoroSync::Ptr  sync) const

◆ waitFor() [1/2]

template<class T >
template<class REP , class PERIOD >
std::future_status Bloomberg::quantum::SharedState< Buffer< T > >::waitFor ( const std::chrono::duration< REP, PERIOD > &  time) const

◆ waitFor() [2/2]

template<class T >
template<class REP , class PERIOD >
std::future_status Bloomberg::quantum::SharedState< Buffer< T > >::waitFor ( ICoroSync::Ptr  sync,
const std::chrono::duration< REP, PERIOD > &  time 
) const

Friends And Related Function Documentation

◆ Promise< Buffer< T > >

template<class T >
friend class Promise< Buffer< T > >
friend