35 : m_speed_multiplier {speed_multiplier} {}
41 auto set_speed(
double speed_multiplier)
noexcept ->
void {
42 m_speed_multiplier = speed_multiplier;
48 [[nodiscard]]
auto speed() const noexcept ->
double {
return m_speed_multiplier; }
60 double m_speed_multiplier {1.0};
Replays a parsed ITCH stream paced by message timestamps.
ReplayEngine(double speed_multiplier=1.0) noexcept
Constructs an engine with a speed multiplier.
auto speed() const noexcept -> double
The current speed multiplier.
auto replay(std::span< const std::byte > data, const MessageCallback &callback) const -> std::uint64_t
Parses data and invokes callback for each message, paced by the message timestamps.
auto set_speed(double speed_multiplier) noexcept -> void
Sets the speed multiplier (see the constructor).
std::function< void(const Message &)> MessageCallback
The signature for the callback function used in streaming parse methods.
Public parsing interface for NASDAQ TotalView-ITCH 5.0 feeds, plus the low-level byte-unpacking utili...