Consumer::operator() can optionally return AtomicNotificationQueueTaskStatus to indicate if the provided task should be considered consumed or discarded. Discarded tasks are not counted towards maxReadAtOnce_.

Synopsis

Declared in <folly/io/async/AtomicNotificationQueue.h>

enum class AtomicNotificationQueueTaskStatus : uint8_t;

Members

Name

Description

CONSUMED

The dequeued task was consumed and should be counted as such.

CONSUMED_STOP

Same as CONSUMED, but drive() stops early even if maxReadAtOnce_ wasn't reached.

DISCARD

The dequeued task should be discarded and not counted as consumed.

Created with MrDocs