#include <userver/concurrent/queue_helpers.hpp>
Definition at line 96 of file queue_helpers.hpp.
Public Member Functions | |
Consumer (const Consumer &)=delete | |
Consumer (Consumer &&) noexcept=default | |
Consumer & | operator= (const Consumer &)=delete |
Consumer & | operator= (Consumer &&other) noexcept |
bool | Pop (ValueType &value, engine::Deadline deadline={}) const |
bool | PopNoblock (ValueType &value) const |
void | Reset () && |
std::shared_ptr< const QueueType > | Queue () const |
Const access to source queue. | |
|
inline |
Definition at line 114 of file queue_helpers.hpp.
|
inlinenoexcept |
Definition at line 108 of file queue_helpers.hpp.
|
inline |
Pop element from queue. May wait asynchronously if the queue is empty, but the producer is alive.
false
can be returned before the deadline when the producer is no longer alive. Definition at line 123 of file queue_helpers.hpp.
|
inline |
Try to pop element from queue without blocking. May be used in non-coroutine environment
Definition at line 131 of file queue_helpers.hpp.
|
inline |
Const access to source queue.
Definition at line 142 of file queue_helpers.hpp.
|
inline |
Definition at line 135 of file queue_helpers.hpp.