Identifies an unbound sequence of messages. More...
#include <stream_source_driver.hpp>
Inheritance diagram for caf::stream_source_driver< DownstreamManager >:
Public Types | |
| using | downstream_manager_type = DownstreamManager |
Type of the downstream manager, i.e., the type returned by stream_manager::out(). | |
| using | output_type = typename downstream_manager_type::output_type |
| Element type of the output stream. | |
| using | stream_type = stream< output_type > |
| Type of the output stream. | |
| using | source_type = stream_source< downstream_manager_type > |
Implemented stream_source interface. | |
| using | source_ptr_type = intrusive_ptr< source_type > |
| Smart pointer to the interface type. | |
Public Member Functions | |
| virtual void | finalize (const error &) |
| Cleans up any state. | |
| virtual void | pull (downstream< output_type > &dst, size_t num)=0 |
Generates more elements for dst. | |
| virtual bool | done () const noexcept=0 |
Returns true if the source is done sending, otherwise false. | |
Detailed Description
template<class DownstreamManager>
class caf::stream_source_driver< DownstreamManager >
class caf::stream_source_driver< DownstreamManager >
Identifies an unbound sequence of messages.
Member Function Documentation
◆ done()
template<class DownstreamManager >
|
pure virtualnoexcept |
Returns true if the source is done sending, otherwise false.
Implemented in caf::detail::stream_source_driver_impl< DownstreamManager, Pull, Done, Finalize >.
◆ finalize()
template<class DownstreamManager >
|
virtual |
Cleans up any state.
Reimplemented in caf::detail::stream_source_driver_impl< DownstreamManager, Pull, Done, Finalize >.
◆ pull()
template<class DownstreamManager >
|
pure virtual |
Generates more elements for dst.
Implemented in caf::detail::stream_source_driver_impl< DownstreamManager, Pull, Done, Finalize >.
The documentation for this class was generated from the following file:
- libcaf_core/caf/stream_source_driver.hpp
