#include <observed_queue.h>
Public Member Functions | |
virtual bool | empty () const =0 |
virtual void | setStatusMonitor (std::shared_ptr< StatusMonitor > status_monitor)=0 |
virtual size_t | size () const =0 |
Public Member Functions inherited from Aws::DataFlow::Sink< T > | |
virtual void | clear ()=0 |
virtual bool | enqueue (T &&value)=0 |
virtual bool | enqueue (T &value)=0 |
virtual bool | tryEnqueue (T &value, const std::chrono::microseconds &duration)=0 |
virtual bool | tryEnqueue (T &&value, const std::chrono::microseconds &duration)=0 |
Public Member Functions inherited from Aws::DataFlow::Source< T > | |
virtual bool | dequeue (T &, const std::chrono::microseconds &duration)=0 |
virtual | ~Source ()=default |
Definition at line 33 of file observed_queue.h.
|
pure virtual |
|
pure virtual |
Implemented in Aws::DataFlow::ObservedQueue< T, Allocator >, and MockObservedQueue.
|
pure virtual |