caf::async::publisher< T > Class Template Reference

Provides an interface for accessing an asynchronous data flow. More...

#include <publisher.hpp>

Public Member Functions
	publisher (publisher &&) noexcept=default
	publisher (const publisher &) noexcept=default
publisher &	operator= (publisher &&) noexcept=default
publisher &	operator= (const publisher &) noexcept=default
flow::observable< T >	observe_on (flow::coordinator *parent, size_t buffer_size, size_t min_request_size) const
	Creates a flow::observable that reads and emits all values from this publisher.
flow::observable< T >	observe_on (flow::coordinator *parent) const
	Creates a flow::observable that reads and emits all values from this publisher.

Static Public Member Functions
static publisher	from (flow::observable< T > decorated)
	Creates a new asynchronous observable by decorating a regular observable.

Detailed Description

template<class T>
class caf::async::publisher< T >

Provides an interface for accessing an asynchronous data flow.

Unlike a future, a publisher produces multiple values over time. Subscribers will only receive items that are emitted after they have subscribed to the publisher.

---

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

• libcaf_core/caf/async/fwd.hpp
• libcaf_core/caf/async/publisher.hpp