Function processing_thread_func

dev/sample/async_chained_handlers/main.cpp:259–277

Thread for final request processing operations.

// Thread for final request processing operations.
void processing_thread_func( const so_5::mchain_t& req_ch )
{
	// This flag will be set to 'true' when some of channels will be closed.
	bool stop = false;
	receive(
		so_5::from( req_ch ).handle_all()
			// If some channel become closed we should set out 'stop' flag.
			.on_close( [&stop](const auto &) { stop = true; } )
			// A predicate for stopping receive() function.
			.stop_on( [&stop]{ return stop; } ),

		// The handler of incoming request.
		[router = create_request_handler()]
		( so_5::mutable_mhood_t<do_processing> cmd ) {
			// Just call an actual router for request processing.
			// All futher processing will be performed synchronously.
			std::ignore = (*router)(cmd->m_controller->request_handle());
		});
}

int main()
{