proxygen
QueueConsumer Member List

This is the complete list of members for QueueConsumer, including all inherited members.

Consumer()folly::NotificationQueue< MessageT >::Consumerinline
consumeUntilDrained(size_t *numConsumed=nullptr) noexceptfolly::NotificationQueue< MessageT >::Consumer
DelayedDestruction()folly::DelayedDestructioninlineprotected
DelayedDestructionBase()folly::DelayedDestructionBaseinlineprotected
destroy() overridefolly::NotificationQueue< MessageT >::Consumerprotectedvirtual
fnQueueConsumer
getCurrentQueue() const folly::NotificationQueue< MessageT >::Consumerinline
getDestroyPending() const folly::DelayedDestructioninline
getDestructorGuardCount() const folly::DelayedDestructionBaseinlineprotected
getEventBase()folly::NotificationQueue< MessageT >::Consumerinline
getMaxReadAtOnce() const folly::NotificationQueue< MessageT >::Consumerinline
handlerReady(uint16_t events) noexceptoverridefolly::NotificationQueue< MessageT >::Consumervirtual
kDefaultMaxReadAtOnce enum valuefolly::NotificationQueue< MessageT >::Consumer
make(TCallback &&callback)folly::NotificationQueue< MessageT >::Consumerstatic
make(TCallback &&callback)folly::NotificationQueue< MessageT >::Consumer
messageAvailable(int &&value) noexceptoverrideQueueConsumerinline
folly::NotificationQueue::Consumer::messageAvailable(MessageT &&message) noexcept=0folly::NotificationQueue< MessageT >::Consumerpure virtual
messagesQueueConsumer
QueueConsumer()QueueConsumerinline
setMaxReadAtOnce(uint32_t maxAtOnce)folly::NotificationQueue< MessageT >::Consumerinline
startConsuming(EventBase *eventBase, NotificationQueue *queue)folly::NotificationQueue< MessageT >::Consumerinline
startConsumingInternal(EventBase *eventBase, NotificationQueue *queue)folly::NotificationQueue< MessageT >::Consumerinline
stopConsuming()folly::NotificationQueue< MessageT >::Consumer
~Consumer() overridefolly::NotificationQueue< MessageT >::Consumerinlineprotected
~DelayedDestruction() override=defaultfolly::DelayedDestructionprotected
~DelayedDestructionBase()=defaultfolly::DelayedDestructionBasevirtual