caf::async::consumer Class Reference

Base type for asynchronous consumers of an event source. More...

#include <consumer.hpp>

Inheritance diagram for caf::async::consumer:

Public Member Functions
virtual void	on_producer_ready ()=0
	Called to signal that the producer started emitting items.
virtual void	on_producer_wakeup ()=0
	Called to signal to the consumer that the producer added an item to a previously empty source or completed the flow of events.
virtual void	ref_consumer () const noexcept=0
	Increases the reference count of the consumer.
virtual void	deref_consumer () const noexcept=0
	Decreases the reference count of the consumer and destroys the object if necessary.

Related Symbols
(Note that these are not member symbols.)
using	consumer_ptr = intrusive_ptr<consumer>
void	intrusive_ptr_add_ref (const consumer *p) noexcept
void	intrusive_ptr_release (const consumer *p) noexcept

Detailed Description

Base type for asynchronous consumers of an event source.

Member Function Documentation

deref_consumer()

virtual void caf::async::consumer::deref_consumer ( ) const

pure virtualnoexcept

Decreases the reference count of the consumer and destroys the object if necessary.

Implemented in caf::flow::op::from_resource_sub< Buffer >.

on_producer_ready()

virtual void caf::async::consumer::on_producer_ready ( )

pure virtual

Called to signal that the producer started emitting items.

Implemented in caf::flow::op::from_resource_sub< Buffer >.

on_producer_wakeup()

virtual void caf::async::consumer::on_producer_wakeup ( )

pure virtual

Called to signal to the consumer that the producer added an item to a previously empty source or completed the flow of events.

Implemented in caf::flow::op::from_resource_sub< Buffer >.

ref_consumer()

virtual void caf::async::consumer::ref_consumer ( ) const

pure virtualnoexcept

Increases the reference count of the consumer.

Implemented in caf::flow::op::from_resource_sub< Buffer >.

---

The documentation for this class was generated from the following files:

• libcaf_core/caf/async/consumer.hpp
• libcaf_core/caf/async/consumer.cpp