Controls the flow of items from publishers to subscribers. More...

#include <subscription.hpp>

Classes
class	fwd_impl
	Default implementation for subscriptions that forward `request` and `cancel` to a listener. More...

class	impl
	Internal interface of a `subscription`. More...

class	impl_base
	Simple base type for all subscription implementations that implements the reference counting member functions. More...

class	listener
	Describes a listener to the subscription that will receive an event whenever the observer calls `request` or `cancel`. More...

Public Member Functions
	subscription (intrusive_ptr< impl > pimpl) noexcept

subscription &	operator= (std::nullptr_t) noexcept

	subscription (subscription &&) noexcept=default

	subscription (const subscription &) noexcept=default

subscription &	operator= (subscription &&) noexcept=default

subscription &	operator= (const subscription &) noexcept=default

void	dispose ()
	Causes the publisher to stop producing items for the subscriber.

void	request (size_t n)

bool	valid () const noexcept

	operator bool () const noexcept

bool	operator! () const noexcept

impl *	ptr () noexcept

const impl *	ptr () const noexcept

intrusive_ptr< impl >	as_intrusive_ptr () const &noexcept

intrusive_ptr< impl > &&	as_intrusive_ptr () &&noexcept

disposable	as_disposable () const &noexcept

disposable	as_disposable () &&noexcept

bool	disposed () const noexcept

void	swap (subscription &other) noexcept

Detailed Description

Controls the flow of items from publishers to subscribers.

Member Function Documentation

void caf::flow::subscription::dispose ( )

Causes the publisher to stop producing items for the subscriber.

Any in-flight items may still get dispatched.

void caf::flow::subscription::request ( size_t n )

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