#include <streamconversion_helper.h>

Inheritance diagram for CollectorThread< SRCTYPE, DSTTYPE >:

[legend]

Public Member Functions
	CollectorThread (StreamConversionHelper< SRCTYPE, DSTTYPE > &emitter)

const char *	GetName () const

Result< void >	operator() ()

Public Member Functions inherited from ThreadInterfaceTemplate< CollectorThread< SRCTYPE, DSTTYPE > >
	ThreadInterfaceTemplate ()

	ThreadInterfaceTemplate (ThreadInterfaceTemplate &&src)

Public Member Functions inherited from ThreadInterface
	ThreadInterface (const JobInterfaceJumpTablePOD &jmpTable)

	ThreadInterface (ThreadInterface &&src)

Bool	IsRunning () const

Bool	Wait (TimeValue timeout=TIMEVALUE_INFINITE, WAITMODE mode=WAITMODE::DEFAULT) const

Result< void >	Start (THREADPRIORITY priority=THREADPRIORITY::NORMAL)

String	ToString (const FormatStatement *formatStatement=nullptr) const

Result< void >	PrivateResetState ()

Public Member Functions inherited from JobInterface
JOBOPTIONFLAGS	GetJobOptions () const

const Char *	GetName () const

	JobInterface (const JobInterfaceJumpTablePOD &jmpTable)

	~JobInterface () override

	JobInterface (JobInterface &&src)

JobInterface &	operator= (JobInterface &&src)

Bool	Wait (TimeValue timeout=TIMEVALUE_INFINITE, WAITMODE mode=WAITMODE::DEFAULT) const

Result< void >	GetResult (TimeValue timeout=TIMEVALUE_INFINITE, WAITMODE mode=WAITMODE::DEFAULT) const

Result< void >	MoveResult (TimeValue timeout=TIMEVALUE_INFINITE, WAITMODE mode=WAITMODE::DEFAULT)

void	Cancel ()

Bool	IsCancelled () const

void	CancelAndWait (WAITMODE mode=WAITMODE::DEFAULT)

JobInterface *	Enqueue (JobQueueInterface *queue=JOBQUEUE_CURRENT)

Result< void >	AddSubJob (JobInterface *subJob)

template<typename JOB >
Result< void >	AddSubJob (ResultMemT< JOB * > subJob)

template<typename JOBREF >
Result< void >	AddSubJob (ResultMemT< JOBREF > &&subJob)

template<typename GROUP >
Result< void >	AddSubGroup (GROUP *subGroup)

template<typename GROUP >
Result< void >	AddSubGroup (ResultMemT< GROUP * > subGroup)

template<typename GROUP >
Result< void >	AddSubGroup (ResultMemT< GROUP > subGroup)

JobGroupInterface *	GetJobGroup () const

ObservableFinishedBase< JobInterface >	ObservableFinished ()

ObservableCancelledBase< JobInterface >	ObservableCancelled ()

Result< void >	Then (JobInterface next, JobQueueInterface queue=JOBQUEUE_CURRENT)

String	ToString (const FormatStatement *formatStatement=nullptr) const

Private Attributes
StreamConversionHelper< SRCTYPE, DSTTYPE > &	_emitter

Additional Inherited Members
Static Public Member Functions inherited from ThreadInterfaceTemplate< CollectorThread< SRCTYPE, DSTTYPE > >
static ResultMemT< StrongRef< CollectorThread< SRCTYPE, DSTTYPE > > >	Create (ARGS &&... args)

Static Public Member Functions inherited from ThreadInterface
static const ThreadInterface *	GetCurrentThread ()

static Bool	IsMainThread ()

static THREADTYPE	GetCurrentThreadType ()

static THREADTYPE	GetCurrentThreadType (Int &threadIdentifier)

static Result< void >	AssimilateAlienThread ()

Static Public Member Functions inherited from JobInterface
template<JOBCANCELLATION B = JOBCANCELLATION::AUTOMATIC, typename FN , typename... ARGS>
static ResultMemT< JobInterface * >	Create (FN &&src, ARGS &&... args)

static Int	GetCurrentWorkerThreadIndex ()

static Int	GetCurrentThreadCount ()

static Bool	IsCurrentJobCancelled (const JobInterface *optionalJob=nullptr)

static JobStatusInterface *	GetCurrentJob ()

Constructor & Destructor Documentation

◆ CollectorThread()

CollectorThread ( StreamConversionHelper< SRCTYPE, DSTTYPE > & emitter )

explicit

Member Function Documentation

◆ GetName()

const char* GetName ( ) const

◆ operator()()

Result<void> operator() ( )

Member Data Documentation

◆ _emitter

StreamConversionHelper<SRCTYPE, DSTTYPE>& _emitter

private

Public Member Functions

Private Attributes