Class StreamingAtomicProcess

Inheritance Relationships

Base Type

Derived Types

Class Documentation

class StreamingAtomicProcess : public eat::framework::AtomicProcess

streaming process with the following callbacks:

  • initialise() will be called once, after all processes connected to this via non-streaming input ports have been ran (so non-streaming inputs are available)

  • process() will be called many times, as long as any streaming ports are not closed; it should read from streaming input ports, and write to streaming output ports, closing them once there’s no more data to write

  • finalise() will be called once, before processes connected to this via non-streaming output ports are ran

Subclassed by eat::framework::detail::InMemBufferRead< T >, eat::framework::detail::InMemBufferWrite< T >, eat::process::InterleavedStreamingAudioSink, eat::process::InterleavedStreamingAudioSource, eat::process::SilenceDetector

Public Functions

inline virtual void initialise()
inline virtual void process()
inline virtual void finalise()
inline virtual std::optional<float> get_progress()

get progress for this process as a fraction between 0 and 1 if known