#include "Headers/NameHeader.h"
#include "MemoryResources/MemoryResources.h"
#include "Headers/DataHeader.h"
#include "Headers/Stack.h"
#include <catch_amalgamated.hpp>
#include <vector>
#include <fairmq/Tools.h>
#include <fairmq/ProgOptions.h>
#include <gsl/gsl>

Functions
template<typename ContainerT , typename std::enable_if<!std::is_same< ContainerT, fair::mq::MessagePtr >::value, int >::type = 0>
bool	addDataBlock (fair::mq::Parts &parts, o2::header::Stack &&inputStack, ContainerT &&inputData, o2::pmr::FairMQMemoryResource *targetResource=nullptr)

template<typename I , typename F >
auto	forEach (I begin, I end, F &&function)

template<typename F >
auto	forEach (fair::mq::Parts &parts, F &&function)

	TEST_CASE ("getMessage_Stack")

	TEST_CASE ("addDataBlockForEach_test")

Function Documentation

◆ addDataBlock()

template<typename ContainerT , typename std::enable_if<!std::is_same< ContainerT, fair::mq::MessagePtr >::value, int >::type = 0>

bool addDataBlock	(	fair::mq::Parts &	parts,
		o2::header::Stack &&	inputStack,
		ContainerT &&	inputData,
		o2::pmr::FairMQMemoryResource *	targetResource = `nullptr`
	)

Definition at line 30 of file test_FairMQ.cxx.

◆ forEach() [1/2]

template<typename F >

auto forEach	(	fair::mq::Parts &	parts,
		F &&	function
	)

Execute user code (e.g. a lambda) on each data block (header-payload pair) returns the function (same as std::for_each)

Definition at line 91 of file test_FairMQ.cxx.

◆ forEach() [2/2]

template<typename I , typename F >

auto forEach	(	I	begin,
		I	end,
		F &&	function
	)

Definition at line 61 of file test_FairMQ.cxx.

◆ TEST_CASE() [1/2]

TEST_CASE ( "addDataBlockForEach_test" )

Definition at line 150 of file test_FairMQ.cxx.

◆ TEST_CASE() [2/2]

TEST_CASE ( "getMessage_Stack" )