Identifies an unbound sequence of messages. More...

#include <stream_sink_driver_impl.hpp>

Inheritance diagram for caf::detail::stream_sink_driver_impl< Input, Process, Finalize >:

Public Types
using	super = stream_sink_driver< Input >

using	trait = stream_sink_trait_t< Process >

using	state_type = typename trait::state

using	input_type = Input

Public Types inherited from caf::stream_sink_driver< Input >
using	input_type = Input

using	sink_type = stream_sink< input_type >
	Implemented `stream_sink` interface.

using	sink_ptr_type = intrusive_ptr< sink_type >
	Smart pointer to the interface type.

Public Member Functions
template<class Init >
	stream_sink_driver_impl (Init init, Process f, Finalize fin)

void	process (std::vector< input_type > &xs) override
	Processes a single batch.

void	finalize (const error &err) override
	Called after closing the last inbound path.

Public Member Functions inherited from caf::stream_sink_driver< Input >
virtual void	finalize (const error &)
	Called after closing the last inbound path.

virtual void	process (std::vector< input_type > &batch)=0
	Processes a single batch.

virtual int32_t	acquire_credit (inbound_path *path, int32_t desired)
	Acquires credit on an inbound path.

Detailed Description

template<class Input, class Process, class Finalize>
class caf::detail::stream_sink_driver_impl< Input, Process, Finalize >

Identifies an unbound sequence of messages.

Member Function Documentation

template<class Input , class Process , class Finalize >

void caf::detail::stream_sink_driver_impl< Input, Process, Finalize >::finalize ( const error & )

overridevirtual

Called after closing the last inbound path.

template<class Input , class Process , class Finalize >

void caf::detail::stream_sink_driver_impl< Input, Process, Finalize >::process ( std::vector< input_type > & batch )

overridevirtual

Processes a single batch.

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