Skip to main content

chronon::sender::StagePipeline

Groups heterogeneous StageReg / SingleStageReg instances for batch lifecycle calls. More...

#include <StagePipeline.hpp>

Public Functions​

Name
voidreset()
template <ValidPhase P,typename Pred >
void		flushIfAnySlot(Pred && pred)
Flush across read and write slots — for mid-tick flushes where upstream has already written.
template <ValidPhase P,typename Pred >
void		flushIf(Pred && pred)
template <ValidPhase P>
void		beginCycle()
StagePipeline(Stages &... s)

Detailed Description​

template <typename... Stages>
class chronon::sender::StagePipeline;

Groups heterogeneous StageReg / SingleStageReg instances for batch lifecycle calls.

Public Functions Documentation​

function reset​

inline void reset()

function flushIfAnySlot​

template <ValidPhase P,
typename Pred >
inline void flushIfAnySlot(
    Pred && pred
)

Flush across read and write slots — for mid-tick flushes where upstream has already written.

function flushIf​

template <ValidPhase P,
typename Pred >
inline void flushIf(
    Pred && pred
)

function beginCycle​

template <ValidPhase P>
inline void beginCycle()

function StagePipeline​

inline explicit StagePipeline(
    Stages &... s
)

Updated on 2026-05-26 at 05:42:32 +0000